public class ActiveMQProtonRemotingConnection extends AbstractRemotingConnection
closeListeners, creationTime, dataReceived, executor, failureListeners, transportConnection
Constructor and Description |
---|
ActiveMQProtonRemotingConnection(ProtonProtocolManager manager,
AMQPConnectionContext amqpConnection,
Connection transportConnection,
Executor executor) |
Modifier and Type | Method and Description |
---|---|
void |
bufferReceived(Object connectionID,
ActiveMQBuffer buffer)
called by the remoting connection when a buffer is received.
|
boolean |
checkDataReceived()
returns true if any data has been received since the last time this method was called.
|
void |
destroy()
destroys this connection.
|
void |
disconnect(boolean criticalError)
Disconnect the connection, closing all channels
|
void |
disconnect(String scaleDownNodeID,
boolean criticalError)
Disconnect the connection, closing all channels
|
void |
fail(ActiveMQException me,
String scaleDownTargetNodeID)
called when the underlying connection fails.
|
void |
flush()
flush all outstanding data from the connection.
|
Executor |
getExecutor() |
ProtonProtocolManager |
getManager() |
boolean |
isClient()
Returns whether or not the
RemotingConnection is a client |
boolean |
isDestroyed()
Returns true if this
RemotingConnection has been destroyed. |
void |
killMessage(SimpleString nodeID)
if slow consumer is killed,send the msessage to client.
|
addCloseListener, addFailureListener, callClosingListeners, callFailureListeners, createTransportBuffer, fail, getCreationTime, getFailureListeners, getID, getLocalAddress, getRemoteAddress, getTransportConnection, isSupportReconnect, isWritable, removeCloseListener, removeCloseListeners, removeFailureListener, removeFailureListeners, setCloseListeners, setFailureListeners
public ActiveMQProtonRemotingConnection(ProtonProtocolManager manager, AMQPConnectionContext amqpConnection, Connection transportConnection, Executor executor)
public Executor getExecutor()
public ProtonProtocolManager getManager()
public void fail(ActiveMQException me, String scaleDownTargetNodeID)
RemotingConnection
me
- the exception that caused the failurescaleDownTargetNodeID
- the ID of the node where scale down is targetedpublic void destroy()
RemotingConnection
public boolean isClient()
RemotingConnection
RemotingConnection
is a clientpublic boolean isDestroyed()
RemotingConnection
RemotingConnection
has been destroyed.public void disconnect(boolean criticalError)
RemotingConnection
public void disconnect(String scaleDownNodeID, boolean criticalError)
public boolean checkDataReceived()
RemotingConnection
checkDataReceived
in interface RemotingConnection
checkDataReceived
in class AbstractRemotingConnection
public void flush()
RemotingConnection
public void bufferReceived(Object connectionID, ActiveMQBuffer buffer)
BufferHandler
bufferReceived
in interface BufferHandler
bufferReceived
in class AbstractRemotingConnection
connectionID
- the connection the buffer was received onbuffer
- the buffer to decodepublic void killMessage(SimpleString nodeID)
RemotingConnection
Copyright © 2016 The Apache Software Foundation. All rights reserved.