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

Constructor Summary

Constructors

Constructor and Description

BridgeImpl(ServerLocatorInternal serverLocator, int reconnectAttempts, long retryInterval, double retryMultiplier, long maxRetryInterval, UUID nodeUUID, SimpleString name, Queue queue, Executor executor, SimpleString filterString, 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()
protected ClientSessionFactoryInternal	getCurrentFactory()
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()
Transformer	getTransformer()
HandleStatus	handle(MessageReference ref)
boolean	isConnected()
boolean	isStarted()
boolean	isUseDuplicateDetection()
void	pause()
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)
void	start()
void	stop()
String	toString()
protected void	tryScheduleRetryReconnect(int code)

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

Constructor Detail

BridgeImpl

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

Throws:

Exception

Method Detail

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

getTransformer

public Transformer getTransformer()

Specified by:

getTransformer in interface Bridge

isUseDuplicateDetection

public boolean isUseDuplicateDetection()

Specified by:

isUseDuplicateDetection 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

beforeForward

protected ServerMessage beforeForward(ServerMessage message)

getDuplicateBytes

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

Parameters:

message -

Returns:

handle

public HandleStatus handle(MessageReference ref)
                    throws Exception

Specified by:

handle in interface Consumer

Throws:

Exception

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(int code)

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

toString

public String toString()

Overrides:

toString in class Object

fail

protected void fail(boolean permanently)

afterConnect

protected void afterConnect()
                     throws Exception

Throws:

Exception

getCurrentFactory

protected ClientSessionFactoryInternal getCurrentFactory()

Returns:

createSessionFactory

protected ClientSessionFactoryInternal createSessionFactory()
                                                     throws Exception

Throws:

Exception

connect

protected void connect()

scheduleRetryConnect

protected void scheduleRetryConnect()

scheduleRetryConnectFixedTimeout

protected void scheduleRetryConnectFixedTimeout(long milliseconds)