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

Class BridgeImpl

java.lang.Object

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

All Implemented Interfaces:

org.apache.activemq.artemis.api.core.client.SendAcknowledgementHandler, org.apache.activemq.artemis.api.core.client.SessionFailureListener, org.apache.activemq.artemis.core.remoting.FailureListener, org.apache.activemq.artemis.core.server.ActiveMQComponent, Bridge, Consumer, org.apache.activemq.artemis.spi.core.remoting.ReadyListener

Direct Known Subclasses:

ClusterConnectionBridge

public class BridgeImpl
extends Object
implements Bridge, org.apache.activemq.artemis.api.core.client.SessionFailureListener, org.apache.activemq.artemis.api.core.client.SendAcknowledgementHandler, org.apache.activemq.artemis.spi.core.remoting.ReadyListener

A Core BridgeImpl

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 org.apache.activemq.artemis.core.client.impl.ServerLocatorInternal	serverLocator
protected org.apache.activemq.artemis.core.client.impl.ClientSessionInternal	session
protected org.apache.activemq.artemis.core.client.impl.ClientSessionInternal	sessionConsumer
protected org.apache.activemq.artemis.api.core.client.TopologyMember	targetNode
protected String	targetNodeID

Constructor Summary

Constructors

Constructor and Description

BridgeImpl(org.apache.activemq.artemis.core.client.impl.ServerLocatorInternal serverLocator, int initialConnectAttempts, int reconnectAttempts, int reconnectAttemptsSameNode, long retryInterval, double retryMultiplier, long maxRetryInterval, org.apache.activemq.artemis.utils.UUID nodeUUID, org.apache.activemq.artemis.api.core.SimpleString name, Queue queue, Executor executor, Filter filter, org.apache.activemq.artemis.api.core.SimpleString forwardingAddress, ScheduledExecutorService scheduledExecutor, Transformer transformer, boolean useDuplicateDetection, String user, String password, StorageManager storageManager)

Method Summary

Modifier and Type	Method and Description
void	activate()
protected void	afterConnect()
protected ServerMessage	beforeForward(ServerMessage message)
void	beforeReconnect(org.apache.activemq.artemis.api.core.ActiveMQException exception)
protected void	connect()
void	connectionFailed(org.apache.activemq.artemis.api.core.ActiveMQException me, boolean failedOver)
void	connectionFailed(org.apache.activemq.artemis.api.core.ActiveMQException me, boolean failedOver, String scaleDownTargetNodeID)
protected org.apache.activemq.artemis.core.client.impl.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()
org.apache.activemq.artemis.core.client.impl.ClientSessionFactoryImpl	getCSF()
List<MessageReference>	getDeliveringMessages()
static byte[]	getDuplicateBytes(org.apache.activemq.artemis.utils.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()
org.apache.activemq.artemis.api.core.SimpleString	getForwardingAddress()
org.apache.activemq.artemis.spi.core.protocol.RemotingConnection	getForwardingConnection()
org.apache.activemq.artemis.api.core.SimpleString	getName()
Queue	getQueue()
org.apache.activemq.artemis.api.core.client.ClientSessionFactory	getSessionFactory()
org.apache.activemq.artemis.api.core.client.TopologyMember	getTargetNodeFromTopology() for use in tests mainly
Transformer	getTransformer()
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	readyForWriting()
void	resume()
protected void	scheduleRetryConnect()
protected void	scheduleRetryConnectFixedTimeout(long milliseconds)
void	sendAcknowledged(org.apache.activemq.artemis.api.core.Message message)
void	setNotificationService(org.apache.activemq.artemis.core.server.management.NotificationService notificationService)
protected void	setSessionFactory(org.apache.activemq.artemis.core.client.impl.ClientSessionFactoryInternal sfi)
void	start()
void	stop()
String	toManagementString() This method will create a string representation meant for management operations.
String	toString()
protected void	tryScheduleRetryReconnect(org.apache.activemq.artemis.api.core.ActiveMQExceptionType type)

Methods inherited from class java.lang.Object

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

Field Detail

serverLocator

protected final org.apache.activemq.artemis.core.client.impl.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 org.apache.activemq.artemis.core.client.impl.ClientSessionInternal session

sessionConsumer

protected volatile org.apache.activemq.artemis.core.client.impl.ClientSessionInternal sessionConsumer

targetNodeID

protected String targetNodeID

targetNode

protected org.apache.activemq.artemis.api.core.client.TopologyMember targetNode

Constructor Detail

BridgeImpl

public BridgeImpl(org.apache.activemq.artemis.core.client.impl.ServerLocatorInternal serverLocator,
                  int initialConnectAttempts,
                  int reconnectAttempts,
                  int reconnectAttemptsSameNode,
                  long retryInterval,
                  double retryMultiplier,
                  long maxRetryInterval,
                  org.apache.activemq.artemis.utils.UUID nodeUUID,
                  org.apache.activemq.artemis.api.core.SimpleString name,
                  Queue queue,
                  Executor executor,
                  Filter filter,
                  org.apache.activemq.artemis.api.core.SimpleString forwardingAddress,
                  ScheduledExecutorService scheduledExecutor,
                  Transformer transformer,
                  boolean useDuplicateDetection,
                  String user,
                  String password,
                  StorageManager storageManager)

Method Detail

getDuplicateBytes

public static final byte[] getDuplicateBytes(org.apache.activemq.artemis.utils.UUID nodeUUID,
                                             long messageID)

getSessionFactory

public org.apache.activemq.artemis.api.core.client.ClientSessionFactory getSessionFactory()

getDeliveringMessages

public List<MessageReference> getDeliveringMessages()

Specified by:

getDeliveringMessages in interface Consumer

Returns:

the list of messages being delivered

setNotificationService

public void setNotificationService(org.apache.activemq.artemis.core.server.management.NotificationService notificationService)

Specified by:

setNotificationService in interface Bridge

start

public void start()
           throws Exception

Specified by:

start in interface org.apache.activemq.artemis.core.server.ActiveMQComponent

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

Specified by:

disconnect in interface Consumer

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 org.apache.activemq.artemis.core.server.ActiveMQComponent

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 org.apache.activemq.artemis.core.server.ActiveMQComponent

activate

public void activate()

getName

public org.apache.activemq.artemis.api.core.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 org.apache.activemq.artemis.api.core.SimpleString getForwardingAddress()

Specified by:

getForwardingAddress in interface Bridge

getForwardingConnection

public org.apache.activemq.artemis.spi.core.protocol.RemotingConnection getForwardingConnection()

Specified by:

getForwardingConnection in interface Bridge

sendAcknowledged

public void sendAcknowledged(org.apache.activemq.artemis.api.core.Message message)

Specified by:

sendAcknowledged in interface org.apache.activemq.artemis.api.core.client.SendAcknowledgementHandler

isPlainCoreBridge

protected boolean isPlainCoreBridge()

beforeForward

protected ServerMessage beforeForward(ServerMessage message)

readyForWriting

public void readyForWriting()

Specified by:

readyForWriting in interface org.apache.activemq.artemis.spi.core.remoting.ReadyListener

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(org.apache.activemq.artemis.api.core.ActiveMQException me,
                             boolean failedOver)

Specified by:

connectionFailed in interface org.apache.activemq.artemis.core.remoting.FailureListener

connectionFailed

public void connectionFailed(org.apache.activemq.artemis.api.core.ActiveMQException me,
                             boolean failedOver,
                             String scaleDownTargetNodeID)

Specified by:

connectionFailed in interface org.apache.activemq.artemis.core.remoting.FailureListener

tryScheduleRetryReconnect

protected void tryScheduleRetryReconnect(org.apache.activemq.artemis.api.core.ActiveMQExceptionType type)

beforeReconnect

public void beforeReconnect(org.apache.activemq.artemis.api.core.ActiveMQException exception)

Specified by:

beforeReconnect in interface org.apache.activemq.artemis.api.core.client.SessionFailureListener

getTargetNodeFromTopology

public org.apache.activemq.artemis.api.core.client.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:

getCSF

public org.apache.activemq.artemis.core.client.impl.ClientSessionFactoryImpl getCSF()

getTransformer

public Transformer getTransformer()

fail

protected void fail(boolean permanently)

afterConnect

protected void afterConnect()
                     throws Exception

Throws:

Exception

createSessionFactory

protected org.apache.activemq.artemis.core.client.impl.ClientSessionFactoryInternal createSessionFactory()
                                                                                                  throws Exception

Throws:

Exception

setSessionFactory

protected void setSessionFactory(org.apache.activemq.artemis.core.client.impl.ClientSessionFactoryInternal sfi)

connect

protected void connect()

scheduleRetryConnect

protected void scheduleRetryConnect()

scheduleRetryConnectFixedTimeout

protected void scheduleRetryConnectFixedTimeout(long milliseconds)