public class BridgeImpl extends Object implements Bridge, SessionFailureListener, SendAcknowledgementHandler, ReadyListener
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 |
protected ClientSessionInternal |
sessionConsumer |
protected TopologyMember |
targetNode |
protected String |
targetNodeID |
Constructor and Description |
---|
BridgeImpl(ServerLocatorInternal serverLocator,
int initialConnectAttempts,
int reconnectAttempts,
int reconnectAttemptsSameNode,
long retryInterval,
double retryMultiplier,
long maxRetryInterval,
UUID nodeUUID,
SimpleString name,
Queue queue,
Executor executor,
Filter filter,
SimpleString forwardingAddress,
ScheduledExecutorService scheduledExecutor,
Transformer transformer,
boolean useDuplicateDetection,
String user,
String password,
ActiveMQServer server) |
Modifier and Type | Method and Description |
---|---|
void |
activate() |
protected void |
afterConnect() |
protected ServerMessage |
beforeForward(ServerMessage message) |
void |
beforeReconnect(ActiveMQException exception) |
protected void |
connect() |
void |
connectionFailed(ActiveMQException me,
boolean failedOver) |
void |
connectionFailed(ActiveMQException me,
boolean failedOver,
String scaleDownTargetNodeID) |
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() |
ClientSessionFactoryImpl |
getCSF() |
List<MessageReference> |
getDeliveringMessages() |
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() |
ClientSessionFactory |
getSessionFactory() |
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(Message message) |
void |
setNotificationService(NotificationService notificationService) |
protected void |
setSessionFactory(ClientSessionFactoryInternal sfi) |
void |
start() |
void |
stop() |
String |
toManagementString()
This method will create a string representation meant for management operations.
|
String |
toString() |
protected void |
tryScheduleRetryReconnect(ActiveMQExceptionType type) |
protected final ServerLocatorInternal serverLocator
protected final Executor executor
protected final ScheduledExecutorService scheduledExecutor
protected ScheduledFuture<?> futureScheduledReconnection
protected volatile ClientSessionInternal session
protected volatile ClientSessionInternal sessionConsumer
protected String targetNodeID
protected TopologyMember targetNode
public BridgeImpl(ServerLocatorInternal serverLocator, int initialConnectAttempts, int reconnectAttempts, int reconnectAttemptsSameNode, long retryInterval, double retryMultiplier, long maxRetryInterval, UUID nodeUUID, SimpleString name, Queue queue, Executor executor, Filter filter, SimpleString forwardingAddress, ScheduledExecutorService scheduledExecutor, Transformer transformer, boolean useDuplicateDetection, String user, String password, ActiveMQServer server)
public static final byte[] getDuplicateBytes(UUID nodeUUID, long messageID)
public ClientSessionFactory getSessionFactory()
public List<MessageReference> getDeliveringMessages()
getDeliveringMessages
in interface Consumer
public void setNotificationService(NotificationService notificationService)
setNotificationService
in interface Bridge
public void start() throws Exception
start
in interface ActiveMQComponent
Exception
public void flushExecutor()
flushExecutor
in interface Bridge
public void disconnect()
Bridge
disconnect
in interface Bridge
disconnect
in interface Consumer
public boolean isConnected()
isConnected
in interface Bridge
public Executor getExecutor()
public void stop() throws Exception
stop
in interface ActiveMQComponent
Exception
public void pause() throws Exception
public void resume() throws Exception
public boolean isStarted()
isStarted
in interface ActiveMQComponent
public void activate()
public SimpleString getName()
public SimpleString getForwardingAddress()
getForwardingAddress
in interface Bridge
public RemotingConnection getForwardingConnection()
getForwardingConnection
in interface Bridge
public void sendAcknowledged(Message message)
sendAcknowledged
in interface SendAcknowledgementHandler
protected boolean isPlainCoreBridge()
protected ServerMessage beforeForward(ServerMessage message)
public void readyForWriting()
readyForWriting
in interface ReadyListener
public HandleStatus handle(MessageReference ref) throws Exception
Consumer
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
public void proceedDeliver(MessageReference ref)
Consumer
proceedDeliver
in interface Consumer
public void connectionFailed(ActiveMQException me, boolean failedOver)
connectionFailed
in interface FailureListener
public void connectionFailed(ActiveMQException me, boolean failedOver, String scaleDownTargetNodeID)
connectionFailed
in interface FailureListener
protected void tryScheduleRetryReconnect(ActiveMQExceptionType type)
public void beforeReconnect(ActiveMQException exception)
beforeReconnect
in interface SessionFailureListener
public TopologyMember getTargetNodeFromTopology()
public String toManagementString()
Consumer
toManagementString
in interface Consumer
public ClientSessionFactoryImpl getCSF()
public Transformer getTransformer()
protected void fail(boolean permanently)
protected ClientSessionFactoryInternal createSessionFactory() throws Exception
Exception
protected void setSessionFactory(ClientSessionFactoryInternal sfi)
protected void connect()
protected void scheduleRetryConnect()
protected void scheduleRetryConnectFixedTimeout(long milliseconds)
Copyright © 2018 The Apache Software Foundation. All Rights Reserved.