public class ClusterConnectionBridge extends BridgeImpl
Such as such adding extra properties and setting up notifications between the nodes.
executor, futureScheduledReconnection, scheduledExecutor, serverLocator, session, sessionConsumer, targetNode, targetNodeID
Constructor and Description |
---|
ClusterConnectionBridge(ClusterConnection clusterConnection,
ClusterManager 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,
Filter 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) |
Modifier and Type | Method and Description |
---|---|
protected void |
afterConnect() |
protected ServerMessage |
beforeForward(ServerMessage message) |
protected ClientSessionFactoryInternal |
createSessionFactory() |
protected void |
fail(boolean permanently) |
protected boolean |
isPlainCoreBridge() |
protected void |
tryScheduleRetryReconnect(HornetQExceptionType type) |
activate, beforeReconnect, connect, connectionFailed, debug, disconnect, flushExecutor, getDeliveringMessages, getDuplicateBytes, getExecutor, getFilter, getForwardingAddress, getForwardingConnection, getName, getQueue, getSessionFactory, getTargetNodeFromTopology, handle, isConnected, isStarted, pause, proceedDeliver, resume, scheduleRetryConnect, scheduleRetryConnectFixedTimeout, sendAcknowledged, setNotificationService, setSessionFactory, start, stop, toManagementString, toString
public ClusterConnectionBridge(ClusterConnection clusterConnection, ClusterManager 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, Filter 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)
protected ClientSessionFactoryInternal createSessionFactory() throws Exception
createSessionFactory
in class BridgeImpl
Exception
protected ServerMessage beforeForward(ServerMessage message)
beforeForward
in class BridgeImpl
protected void afterConnect() throws Exception
afterConnect
in class BridgeImpl
Exception
protected void tryScheduleRetryReconnect(HornetQExceptionType type)
tryScheduleRetryReconnect
in class BridgeImpl
protected void fail(boolean permanently)
fail
in class BridgeImpl
protected boolean isPlainCoreBridge()
isPlainCoreBridge
in class BridgeImpl
Copyright © 2018 JBoss by Red Hat. All rights reserved.