org.apache.activemq.artemis.core.protocol.proton

Class ActiveMQProtonRemotingConnection

java.lang.Object

org.apache.activemq.artemis.spi.core.protocol.AbstractRemotingConnection

org.apache.activemq.artemis.core.protocol.proton.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 org.apache.activemq.artemis.spi.core.protocol.AbstractRemotingConnection

closeListeners, creationTime, dataReceived, executor, failureListeners, transportConnection

Constructor Summary

Constructors

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

Method Summary

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.

Methods inherited from class org.apache.activemq.artemis.spi.core.protocol.AbstractRemotingConnection

addCloseListener, addFailureListener, callClosingListeners, callFailureListeners, createTransportBuffer, fail, getCreationTime, getFailureListeners, getID, getLocalAddress, getRemoteAddress, getTransportConnection, isSupportReconnect, isWritable, removeCloseListener, removeCloseListeners, removeFailureListener, removeFailureListeners, setCloseListeners, setFailureListeners

Methods inherited from class java.lang.Object

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

Constructor Detail

ActiveMQProtonRemotingConnection

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

Method Detail

getExecutor

public Executor getExecutor()

getManager

public ProtonProtocolManager getManager()

fail

public void fail(ActiveMQException me,
                 String scaleDownTargetNodeID)

Description copied from interface: RemotingConnection

called when the underlying connection fails.

Parameters:

me - the exception that caused the failure

scaleDownTargetNodeID - the ID of the node where scale down is targeted

destroy

public void destroy()

Description copied from interface: RemotingConnection

destroys this connection.

isClient

public boolean isClient()

Description copied from interface: RemotingConnection

Returns whether or not the RemotingConnection is a client

Returns:

true if client, false if a server

isDestroyed

public boolean isDestroyed()

Description copied from interface: RemotingConnection

Returns true if this RemotingConnection has been destroyed.

Returns:

true if destroyed, otherwise false

disconnect

public void disconnect(boolean criticalError)

Description copied from interface: RemotingConnection

Disconnect the connection, closing all channels

disconnect

public void disconnect(String scaleDownNodeID,
                       boolean criticalError)

Disconnect the connection, closing all channels

checkDataReceived

public boolean checkDataReceived()

Description copied from interface: RemotingConnection

returns true if any data has been received since the last time this method was called.

Specified by:

checkDataReceived in interface RemotingConnection

Overrides:

checkDataReceived in class AbstractRemotingConnection

Returns:

true if data has been received.

flush

public void flush()

Description copied from interface: RemotingConnection

flush all outstanding data from the connection.

bufferReceived

public void bufferReceived(Object connectionID,
                           ActiveMQBuffer buffer)

Description copied from interface: BufferHandler

called by the remoting connection when a buffer is received.

Specified by:

bufferReceived in interface BufferHandler

Overrides:

bufferReceived in class AbstractRemotingConnection

Parameters:

connectionID - the connection the buffer was received on

buffer - the buffer to decode

killMessage

public void killMessage(SimpleString nodeID)

Description copied from interface: RemotingConnection

if slow consumer is killed,send the msessage to client.