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

public class ActiveMQProtonRemotingConnection
extends AbstractRemotingConnection

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

Constructors

Constructor	Description
ActiveMQProtonRemotingConnection(ProtonProtocolManager manager, AMQPConnectionContext amqpConnection, Connection transportConnection, Executor connectionExecutor)

Method Summary

Modifier and Type	Method	Description
void	bufferReceived(Object connectionID, ActiveMQBuffer buffer)
boolean	checkDataReceived()
void	close()
void	destroy()
void	disconnect(boolean criticalError)
void	disconnect(String scaleDownNodeID, boolean criticalError)	Disconnect the connection, closing all channels
void	fail(ActiveMQException me, String scaleDownTargetNodeID)	This can be called concurrently by more than one thread so needs to be locked
void	flush()
AMQPConnectionContext	getAmqpConnection()
String	getClientID()
ProtonProtocolManager	getManager()
String	getProtocolName()	Returns the name of the protocol for this Remoting Connection.
Subject	getSubject()
boolean	isSupportsFlowControl()
void	open()
void	scheduledFlush()

Methods 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, setSubject

Methods inherited from class Object

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

Methods inherited from interface BufferHandler

endOfBatch

Methods inherited from interface RemotingConnection

disconnect, isSameTarget

Constructor Details

ActiveMQProtonRemotingConnection

public ActiveMQProtonRemotingConnection(ProtonProtocolManager manager,
 AMQPConnectionContext amqpConnection,
 Connection transportConnection,
 Executor connectionExecutor)

Method Details

getAmqpConnection

public AMQPConnectionContext getAmqpConnection()

getManager

public ProtonProtocolManager getManager()

scheduledFlush

public void scheduledFlush()

Specified by:

scheduledFlush in interface RemotingConnection

Overrides:

scheduledFlush in class AbstractRemotingConnection

fail

public void fail(ActiveMQException me,
 String scaleDownTargetNodeID)

This can be called concurrently by more than one thread so needs to be locked

close

public void close()

Specified by:

close in interface RemotingConnection

Overrides:

close in class AbstractRemotingConnection

destroy

public void destroy()

disconnect

public void disconnect(boolean criticalError)

disconnect

public void disconnect(String scaleDownNodeID,
 boolean criticalError)

Disconnect the connection, closing all channels

checkDataReceived

public boolean checkDataReceived()

Specified by:

checkDataReceived in interface RemotingConnection

Overrides:

checkDataReceived in class AbstractRemotingConnection

flush

public void flush()

Specified by:

flush in interface RemotingConnection

Overrides:

flush in class AbstractRemotingConnection

bufferReceived

public void bufferReceived(Object connectionID,
 ActiveMQBuffer buffer)

Specified by:

bufferReceived in interface BufferHandler

Overrides:

bufferReceived in class AbstractRemotingConnection

getSubject

public Subject getSubject()

Specified by:

getSubject in interface RemotingConnection

Overrides:

getSubject in class AbstractRemotingConnection

isSupportsFlowControl

public boolean isSupportsFlowControl()

Specified by:

isSupportsFlowControl in interface RemotingConnection

Overrides:

isSupportsFlowControl in class AbstractRemotingConnection

getProtocolName

public String getProtocolName()

Returns the name of the protocol for this Remoting Connection.

Returns:

the name of the protocol for this Remoting Connection

getClientID

public String getClientID()

Specified by:

getClientID in interface RemotingConnection

Overrides:

getClientID in class AbstractRemotingConnection

open

public void open()