Package org.apache.activemq.artemis.core.server.cluster.impl

Class ClusterConnectionBridge

java.lang.Object

org.apache.activemq.artemis.core.server.cluster.impl.BridgeImpl

org.apache.activemq.artemis.core.server.cluster.impl.ClusterConnectionBridge

All Implemented Interfaces:

SendAcknowledgementHandler, SessionFailureListener, ClientProducerFlowCallback, PriorityAware, FailureListener, ActiveMQComponent, Bridge, Consumer, ReadyListener

public class ClusterConnectionBridge
extends BridgeImpl

A bridge with extra functionality only available when the server is clustered.

Such as such adding extra properties and setting up notifications between the nodes.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.activemq.artemis.core.server.cluster.impl.BridgeImpl

BridgeImpl.State

Field Summary

Fields inherited from class org.apache.activemq.artemis.core.server.cluster.impl.BridgeImpl

disconnectedAndDown, executor, queue, scheduledExecutor, scheduledReconnection, serverLocator, session, sessionConsumer, targetNode, targetNodeID

Constructor Summary

Constructors

Constructor

Description

ClusterConnectionBridge(ClusterConnection clusterConnection, ClusterManager clusterManager, ServerLocatorInternal targetLocator, ServerLocatorInternal discoveryLocator, int initialConnectAttempts, 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, TransformerConfiguration transformer, boolean useDuplicateDetection, String user, String password, ActiveMQServer server, SimpleString managementAddress, SimpleString managementNotificationAddress, MessageFlowRecord flowRecord, TransportConfiguration connector, String storeAndForwardPrefix, StorageManager storageManager, String clientId)

Method Summary

Modifier and Type	Method	Description
protected void	afterConnect()	Hook for doing extra stuff after connection
protected Message	beforeForward(Message message, SimpleString forwardingAddress)	Hook for processing message before forwarding
static String	buildSelectorFromArray(String[] list)
static String	createSelectorFromAddress(String address)	Takes in a string of an address filter or comma separated list and generates an appropriate JMS selector for filtering queues.
protected ClientSessionFactoryInternal	createSessionFactory()	Hook for creating session factory
protected void	fail(boolean permanently, boolean scaleDown)
protected void	nodeUP(TopologyMember member, boolean last)
protected void	tryScheduleRetryReconnect(ActiveMQExceptionType type)

Methods inherited from class org.apache.activemq.artemis.core.server.cluster.impl.BridgeImpl

beforeForwardingNoCopy, beforeReconnect, connectionFailed, connectionFailed, debug, disconnect, failed, flushExecutor, getConfiguration, getDeliveringMessages, getDuplicateBytes, getExecutor, getFilter, getForwardingAddress, getForwardingConnection, getMetrics, getName, getQueue, getServerLocator, getSessionFactory, getState, getTargetNodeFromTopology, getTransformer, handle, isBlockedOnFlowControl, isConnected, isStarted, onCreditsFail, onCreditsFlow, pause, proceedDeliver, readyForWriting, reconnectOnOriginalNode, resume, scaleDown, scheduleRetryConnect, scheduleRetryConnectFixedTimeout, sendAcknowledged, sendFailed, sequentialID, setNotificationService, setSessionFactory, start, stop, toManagementString, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.activemq.artemis.core.server.ActiveMQComponent

asyncStop

Methods inherited from interface org.apache.activemq.artemis.core.server.Consumer

errorProcessing, getBinding, getPriority, isClosed, promptDelivery, supportsDirectDelivery

Constructor Details

ClusterConnectionBridge

public ClusterConnectionBridge(ClusterConnection clusterConnection,
 ClusterManager clusterManager,
 ServerLocatorInternal targetLocator,
 ServerLocatorInternal discoveryLocator,
 int initialConnectAttempts,
 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,
 TransformerConfiguration transformer,
 boolean useDuplicateDetection,
 String user,
 String password,
 ActiveMQServer server,
 SimpleString managementAddress,
 SimpleString managementNotificationAddress,
 MessageFlowRecord flowRecord,
 TransportConfiguration connector,
 String storeAndForwardPrefix,
 StorageManager storageManager,
 String clientId)
                        throws ActiveMQException

Throws:

ActiveMQException

Method Details

createSessionFactory

protected ClientSessionFactoryInternal createSessionFactory()
                                                     throws Exception

Description copied from class: BridgeImpl

Hook for creating session factory

Overrides:

createSessionFactory in class BridgeImpl

Throws:

Exception

beforeForward

protected Message beforeForward(Message message,
 SimpleString forwardingAddress)

Description copied from class: BridgeImpl

Hook for processing message before forwarding

Overrides:

beforeForward in class BridgeImpl

createSelectorFromAddress

public static String createSelectorFromAddress(String address)

Takes in a string of an address filter or comma separated list and generates an appropriate JMS selector for filtering queues.

buildSelectorFromArray

public static String buildSelectorFromArray(String[] list)

nodeUP

protected void nodeUP(TopologyMember member,
 boolean last)

Overrides:

nodeUP in class BridgeImpl

afterConnect

protected void afterConnect()
                     throws Exception

Description copied from class: BridgeImpl

Hook for doing extra stuff after connection

Overrides:

afterConnect in class BridgeImpl

Throws:

Exception

tryScheduleRetryReconnect

protected void tryScheduleRetryReconnect(ActiveMQExceptionType type)

Overrides:

tryScheduleRetryReconnect in class BridgeImpl

fail

protected void fail(boolean permanently,
 boolean scaleDown)

Overrides:

fail in class BridgeImpl