org.hornetq.core.server.cluster.impl

Class ClusterConnectionBridge

java.lang.Object

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

org.hornetq.core.server.cluster.impl.ClusterConnectionBridge

All Implemented Interfaces:

SendAcknowledgementHandler, SessionFailureListener, FailureListener, Bridge, Consumer, HornetQComponent

public class ClusterConnectionBridge
extends BridgeImpl

A ClusterConnectionBridge

Author:

tim, Clebert Suconic

Field Summary

Fields inherited from class org.hornetq.core.server.cluster.impl.BridgeImpl

executor, futureScheduledReconnection, scheduledExecutor, serverLocator, session

Constructor Summary

Constructors

Constructor and Description

ClusterConnectionBridge(ClusterConnection clusterConnection, ClusterManagerInternal clusterManager, ServerLocatorInternal targetLocator, ServerLocatorInternal discoveryLocator, int reconnectAttempts, long retryInterval, double retryMultiplier, long maxRetryInterval, UUID nodeUUID, long targetNodeEventUID, String targetNodeID, SimpleString name, Queue queue, Executor executor, SimpleString filterString, SimpleString forwardingAddress, ScheduledExecutorService scheduledExecutor, Transformer transformer, boolean useDuplicateDetection, String user, String password, boolean activated, StorageManager storageManager, SimpleString managementAddress, SimpleString managementNotificationAddress, MessageFlowRecord flowRecord, TransportConfiguration connector)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	afterConnect()
protected ServerMessage	beforeForward(ServerMessage message)
protected ClientSessionFactoryInternal	createSessionFactory()
protected void	fail(boolean permanently)
void	stop()
protected void	tryScheduleRetryReconnect(int code)

Methods inherited from class org.hornetq.core.server.cluster.impl.BridgeImpl

activate, beforeReconnect, connect, connectionFailed, debug, disconnect, flushExecutor, getCurrentFactory, getDuplicateBytes, getExecutor, getFilter, getForwardingAddress, getForwardingConnection, getName, getQueue, getTransformer, handle, isConnected, isStarted, isUseDuplicateDetection, pause, resume, scheduleRetryConnect, scheduleRetryConnectFixedTimeout, sendAcknowledged, setNotificationService, start, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusterConnectionBridge

public ClusterConnectionBridge(ClusterConnection clusterConnection,
                       ClusterManagerInternal clusterManager,
                       ServerLocatorInternal targetLocator,
                       ServerLocatorInternal discoveryLocator,
                       int reconnectAttempts,
                       long retryInterval,
                       double retryMultiplier,
                       long maxRetryInterval,
                       UUID nodeUUID,
                       long targetNodeEventUID,
                       String targetNodeID,
                       SimpleString name,
                       Queue queue,
                       Executor executor,
                       SimpleString filterString,
                       SimpleString forwardingAddress,
                       ScheduledExecutorService scheduledExecutor,
                       Transformer transformer,
                       boolean useDuplicateDetection,
                       String user,
                       String password,
                       boolean activated,
                       StorageManager storageManager,
                       SimpleString managementAddress,
                       SimpleString managementNotificationAddress,
                       MessageFlowRecord flowRecord,
                       TransportConfiguration connector)
                        throws Exception

Throws:

Exception

Method Detail

createSessionFactory

protected ClientSessionFactoryInternal createSessionFactory()
                                                     throws Exception

Overrides:

createSessionFactory in class BridgeImpl

Throws:

Exception

beforeForward

protected ServerMessage beforeForward(ServerMessage message)

Overrides:

beforeForward in class BridgeImpl

afterConnect

protected void afterConnect()
                     throws Exception

Overrides:

afterConnect in class BridgeImpl

Throws:

Exception

stop

public void stop()
          throws Exception

Specified by:

stop in interface HornetQComponent

Overrides:

stop in class BridgeImpl

Throws:

Exception

tryScheduleRetryReconnect

protected void tryScheduleRetryReconnect(int code)

Overrides:

tryScheduleRetryReconnect in class BridgeImpl

fail

protected void fail(boolean permanently)

Overrides:

fail in class BridgeImpl