org.hornetq.core.server.cluster.impl

Class BridgeImpl

java.lang.Object

org.hornetq.core.server.cluster.impl.BridgeImpl

All Implemented Interfaces:

SendAcknowledgementHandler, SessionFailureListener, FailureListener, Bridge, Consumer, HornetQComponent

Direct Known Subclasses:

ClusterConnectionBridge

public class BridgeImpl
extends Object
implements Bridge, SessionFailureListener, SendAcknowledgementHandler

A Core BridgeImpl

Author:

Tim Fox, Jeff Mesnil, Clebert Suconic

Created 12 Nov 2008 11:37:35

Field Summary

Fields

Modifier and Type	Field and Description
protected Executor	executor
protected ScheduledFuture<?>	futureScheduledReconnection Used when there's a scheduled reconnection
protected ScheduledExecutorService	scheduledExecutor
protected ServerLocatorInternal	serverLocator
protected ClientSessionInternal	session
protected ClientSessionInternal	sessionConsumer
protected TopologyMember	targetNode
protected String	targetNodeID

Constructor Summary

Constructors

Constructor and Description
BridgeImpl(ServerLocatorInternal serverLocator, int reconnectAttempts, int initialConnectAttempts, int reconnectAttemptsSameNode, long retryInterval, double retryMultiplier, long maxRetryInterval, UUID nodeUUID, SimpleString name, Queue queue, Executor executor, Filter filter, SimpleString forwardingAddress, ScheduledExecutorService scheduledExecutor, Transformer transformer, boolean useDuplicateDetection, String user, String password, boolean activated, StorageManager storageManager)
BridgeImpl(ServerLocatorInternal serverLocator, int reconnectAttempts, int reconnectAttemptsSameNode, long retryInterval, double retryMultiplier, long maxRetryInterval, UUID nodeUUID, SimpleString name, Queue queue, Executor executor, Filter filter, SimpleString forwardingAddress, ScheduledExecutorService scheduledExecutor, Transformer transformer, boolean useDuplicateDetection, String user, String password, boolean activated, StorageManager storageManager)

Method Summary

Methods

Modifier and Type	Method and Description
void	activate()
protected void	afterConnect()
protected ServerMessage	beforeForward(ServerMessage message)
void	beforeReconnect(HornetQException exception) Notifies that a connection has failed due to the specified exception.
protected void	connect()
void	connectionFailed(HornetQException me, boolean failedOver) Notifies that a connection has failed due to the specified exception.
protected ClientSessionFactoryInternal	createSessionFactory()
String	debug()
void	disconnect() To be called when the server sent a disconnect to the client.
protected void	fail(boolean permanently)
void	flushExecutor()
List<MessageReference>	getDeliveringMessages() Add the in-deliver mode messages to the ref-list passed as parameter
static byte[]	getDuplicateBytes(UUID nodeUUID, long messageID)
Executor	getExecutor() The cluster manager needs to use the same executor to close the serverLocator, otherwise the stop will break.
Filter	getFilter()
SimpleString	getForwardingAddress()
RemotingConnection	getForwardingConnection()
SimpleString	getName()
Queue	getQueue()
ClientSessionFactory	getSessionFactory()
TopologyMember	getTargetNodeFromTopology() for use in tests mainly
HandleStatus	handle(MessageReference ref) There was a change on semantic during 2.3 here. We now first accept the message, and the actual deliver is done as part of Consumer.proceedDeliver(MessageReference).
boolean	isConnected()
protected boolean	isPlainCoreBridge()
boolean	isStarted()
void	pause()
void	proceedDeliver(MessageReference ref) This will proceed with the actual delivery.
void	resume()
protected void	scheduleRetryConnect()
protected void	scheduleRetryConnectFixedTimeout(long milliseconds)
void	sendAcknowledged(Message message) Notifies the client that a message sent asynchronously has been received by the server.
void	setNotificationService(NotificationService notificationService)
protected void	setSessionFactory(ClientSessionFactoryInternal sfi)
void	start()
void	stop()
String	toManagementString() This method will create a string representation meant for management operations.
String	toString()
protected void	tryScheduleRetryReconnect(HornetQExceptionType type)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

serverLocator

protected final ServerLocatorInternal serverLocator

executor

protected final Executor executor

scheduledExecutor

protected final ScheduledExecutorService scheduledExecutor

futureScheduledReconnection

protected ScheduledFuture<?> futureScheduledReconnection

Used when there's a scheduled reconnection

session

protected volatile ClientSessionInternal session

sessionConsumer

protected volatile ClientSessionInternal sessionConsumer

targetNodeID

protected String targetNodeID

targetNode

protected TopologyMember targetNode

Constructor Detail

BridgeImpl

public BridgeImpl(ServerLocatorInternal serverLocator,
          int reconnectAttempts,
          int reconnectAttemptsSameNode,
          long retryInterval,
          double retryMultiplier,
          long maxRetryInterval,
          UUID nodeUUID,
          SimpleString name,
          Queue queue,
          Executor executor,
          Filter filter,
          SimpleString forwardingAddress,
          ScheduledExecutorService scheduledExecutor,
          Transformer transformer,
          boolean useDuplicateDetection,
          String user,
          String password,
          boolean activated,
          StorageManager storageManager)

BridgeImpl

public BridgeImpl(ServerLocatorInternal serverLocator,
          int reconnectAttempts,
          int initialConnectAttempts,
          int reconnectAttemptsSameNode,
          long retryInterval,
          double retryMultiplier,
          long maxRetryInterval,
          UUID nodeUUID,
          SimpleString name,
          Queue queue,
          Executor executor,
          Filter filter,
          SimpleString forwardingAddress,
          ScheduledExecutorService scheduledExecutor,
          Transformer transformer,
          boolean useDuplicateDetection,
          String user,
          String password,
          boolean activated,
          StorageManager storageManager)

Method Detail

getDuplicateBytes

public static final byte[] getDuplicateBytes(UUID nodeUUID,
                       long messageID)

getSessionFactory

public ClientSessionFactory getSessionFactory()

getDeliveringMessages

public List<MessageReference> getDeliveringMessages()

Description copied from interface: Consumer

Add the in-deliver mode messages to the ref-list passed as parameter

Specified by:

getDeliveringMessages in interface Consumer

setNotificationService

public void setNotificationService(NotificationService notificationService)

Specified by:

setNotificationService in interface Bridge

start

public void start()
           throws Exception

Specified by:

start in interface HornetQComponent

Throws:

Exception

debug

public String debug()

Specified by:

debug in interface Consumer

flushExecutor

public void flushExecutor()

Specified by:

flushExecutor in interface Bridge

disconnect

public void disconnect()

Description copied from interface: Bridge

To be called when the server sent a disconnect to the client. Basically this is for cluster bridges being disconnected

Specified by:

disconnect in interface Bridge

isConnected

public boolean isConnected()

Specified by:

isConnected in interface Bridge

getExecutor

public Executor getExecutor()

The cluster manager needs to use the same executor to close the serverLocator, otherwise the stop will break. This method is intended to expose this executor to the ClusterManager

stop

public void stop()
          throws Exception

Specified by:

stop in interface HornetQComponent

Throws:

Exception

pause

public void pause()
           throws Exception

Specified by:

pause in interface Bridge

Throws:

Exception

resume

public void resume()
            throws Exception

Specified by:

resume in interface Bridge

Throws:

Exception

isStarted

public boolean isStarted()

Specified by:

isStarted in interface HornetQComponent

activate

public void activate()

Specified by:

activate in interface Bridge

getName

public SimpleString getName()

Specified by:

getName in interface Bridge

getQueue

public Queue getQueue()

Specified by:

getQueue in interface Bridge

getFilter

public Filter getFilter()

Specified by:

getFilter in interface Consumer

getForwardingAddress

public SimpleString getForwardingAddress()

Specified by:

getForwardingAddress in interface Bridge

getForwardingConnection

public RemotingConnection getForwardingConnection()

Specified by:

getForwardingConnection in interface Bridge

sendAcknowledged

public void sendAcknowledged(Message message)

Description copied from interface: SendAcknowledgementHandler

Notifies the client that a message sent asynchronously has been received by the server.

Specified by:

sendAcknowledged in interface SendAcknowledgementHandler

Parameters:

message - message sent asynchronously

isPlainCoreBridge

protected boolean isPlainCoreBridge()

beforeForward

protected ServerMessage beforeForward(ServerMessage message)

handle

public HandleStatus handle(MessageReference ref)
                    throws Exception

Description copied from interface: Consumer

There was a change on semantic during 2.3 here.
We now first accept the message, and the actual deliver is done as part of Consumer.proceedDeliver(MessageReference). This is to avoid holding a lock on the queues while the delivery is being accomplished To avoid a lock on the queue in case of misbehaving consumers.

This should return busy if handle is called before proceed deliver is called

Specified by:

handle in interface Consumer

Returns:

Throws:

Exception

proceedDeliver

public void proceedDeliver(MessageReference ref)

Description copied from interface: Consumer

This will proceed with the actual delivery. Notice that handle should hold a readLock and proceedDelivery should release the readLock any lock operation on Consumer should also get a writeLock on the readWriteLock to guarantee there are no pending deliveries

Specified by:

proceedDeliver in interface Consumer

connectionFailed

public void connectionFailed(HornetQException me,
                    boolean failedOver)

Description copied from interface: FailureListener

Notifies that a connection has failed due to the specified exception.

Specified by:

connectionFailed in interface FailureListener

Parameters:

me - exception which has caused the connection to fail

tryScheduleRetryReconnect

protected void tryScheduleRetryReconnect(HornetQExceptionType type)

beforeReconnect

public void beforeReconnect(HornetQException exception)

Description copied from interface: SessionFailureListener

Notifies that a connection has failed due to the specified exception.
This method is called before the session attempts to reconnect/failover.

Specified by:

beforeReconnect in interface SessionFailureListener

Parameters:

exception - exception which has caused the connection to fail

getTargetNodeFromTopology

public TopologyMember getTargetNodeFromTopology()

for use in tests mainly

Returns:

toString

public String toString()

Overrides:

toString in class Object

toManagementString

public String toManagementString()

Description copied from interface: Consumer

This method will create a string representation meant for management operations. This is different from the toString method that's meant for debugging and will contain information that regular users won't understand well

Specified by:

toManagementString in interface Consumer

Returns:

fail

protected void fail(boolean permanently)

afterConnect

protected void afterConnect()
                     throws Exception

Throws:

Exception

createSessionFactory

protected ClientSessionFactoryInternal createSessionFactory()
                                                     throws Exception

Throws:

Exception

setSessionFactory

protected void setSessionFactory(ClientSessionFactoryInternal sfi)

connect

protected void connect()

scheduleRetryConnect

protected void scheduleRetryConnect()

scheduleRetryConnectFixedTimeout

protected void scheduleRetryConnectFixedTimeout(long milliseconds)