Class ActiveMQProtonRemotingConnection
java.lang.Object
org.apache.activemq.artemis.spi.core.protocol.AbstractRemotingConnection
org.apache.activemq.artemis.protocol.amqp.broker.ActiveMQProtonRemotingConnection
- All Implemented Interfaces:
RemotingConnection, BufferHandler
This is a Server's Connection representation used by ActiveMQ Artemis.
-
Field Summary
Fields inherited from class AbstractRemotingConnection
closeListeners, creationTime, dataReceived, destroyed, executor, failureListeners, transportConnection -
Constructor Summary
ConstructorsConstructorDescriptionActiveMQProtonRemotingConnection(ProtonProtocolManager manager, AMQPConnectionContext amqpConnection, Connection transportConnection, Executor connectionExecutor) -
Method Summary
Modifier and TypeMethodDescriptionvoidbufferReceived(Object connectionID, ActiveMQBuffer buffer) booleanvoidclose()voiddestroy()voiddisconnect(boolean criticalError) voiddisconnect(String scaleDownNodeID, boolean criticalError) Disconnect the connection, closing all channelsvoidfail(ActiveMQException me, String scaleDownTargetNodeID) This can be called concurrently by more than one thread so needs to be lockedvoidflush()Returns the name of the protocol for this Remoting Connection.booleanvoidopen()voidMethods inherited from class AbstractRemotingConnection
addCloseListener, addFailureListener, asyncFail, callClosingListeners, callFailureListeners, createTransportBuffer, fail, getCreationTime, getFailureListeners, getID, getLocalAddress, getRemoteAddress, getTransportConnection, getTransportLocalAddress, isClient, isDestroyed, isSupportReconnect, isWritable, killMessage, removeCloseListener, removeCloseListeners, removeFailureListener, removeFailureListeners, setClientID, setCloseListeners, setFailureListeners, setSubjectMethods inherited from class Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface BufferHandler
endOfBatchMethods inherited from interface RemotingConnection
disconnect, isSameTarget
-
Constructor Details
-
ActiveMQProtonRemotingConnection
public ActiveMQProtonRemotingConnection(ProtonProtocolManager manager, AMQPConnectionContext amqpConnection, Connection transportConnection, Executor connectionExecutor)
-
-
Method Details
-
getAmqpConnection
-
getManager
-
scheduledFlush
public void scheduledFlush()- Specified by:
scheduledFlushin interfaceRemotingConnection- Overrides:
scheduledFlushin classAbstractRemotingConnection
-
fail
This can be called concurrently by more than one thread so needs to be locked -
close
public void close()- Specified by:
closein interfaceRemotingConnection- Overrides:
closein classAbstractRemotingConnection
-
destroy
public void destroy() -
disconnect
public void disconnect(boolean criticalError) -
disconnect
Disconnect the connection, closing all channels -
checkDataReceived
public boolean checkDataReceived()- Specified by:
checkDataReceivedin interfaceRemotingConnection- Overrides:
checkDataReceivedin classAbstractRemotingConnection
-
flush
public void flush()- Specified by:
flushin interfaceRemotingConnection- Overrides:
flushin classAbstractRemotingConnection
-
bufferReceived
- Specified by:
bufferReceivedin interfaceBufferHandler- Overrides:
bufferReceivedin classAbstractRemotingConnection
-
getSubject
- Specified by:
getSubjectin interfaceRemotingConnection- Overrides:
getSubjectin classAbstractRemotingConnection
-
isSupportsFlowControl
public boolean isSupportsFlowControl()- Specified by:
isSupportsFlowControlin interfaceRemotingConnection- Overrides:
isSupportsFlowControlin classAbstractRemotingConnection
-
getProtocolName
Returns the name of the protocol for this Remoting Connection.- Returns:
- the name of the protocol for this Remoting Connection
-
getClientID
- Specified by:
getClientIDin interfaceRemotingConnection- Overrides:
getClientIDin classAbstractRemotingConnection
-
open
public void open()
-