Package org.apache.activemq.artemis.core.protocol.core.impl

Class RemotingConnectionImpl

java.lang.Object

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

org.apache.activemq.artemis.core.protocol.core.impl.RemotingConnectionImpl

All Implemented Interfaces:

CoreRemotingConnection, RemotingConnection, BufferHandler

public class RemotingConnectionImpl
extends AbstractRemotingConnection
implements CoreRemotingConnection

Field Summary

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

closeListeners, creationTime, dataReceived, destroyed, executor, failureListeners, transportConnection

Constructor Summary

Constructors

Constructor	Description
RemotingConnectionImpl(PacketDecoder packetDecoder, Connection transportConnection, long blockingCallTimeout, long blockingCallFailoverTimeout, List<Interceptor> incomingInterceptors, List<Interceptor> outgoingInterceptors, Executor connectionExecutor)	Create a client side connection
RemotingConnectionImpl(PacketDecoder packetDecoder, Connection transportConnection, List<Interceptor> incomingInterceptors, List<Interceptor> outgoingInterceptors, SimpleString nodeID, Executor connectionExecutor)	Create a server side connection

Method Summary

Modifier and Type	Method	Description
boolean	blockUntilWritable(long timeout)
void	bufferReceived(Object connectionID, ActiveMQBuffer buffer)	called by the remoting connection when a buffer is received.
void	close()
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	disconnect(DisconnectReason reason, String targetNodeID, TransportConfiguration targetConnector)	Disconnect the connection, closing all channels
void	endOfBatch(Object connectionID)
void	fail(ActiveMQException me, String scaleDownTargetNodeID)	called when the underlying connection fails.
void	flush()	flush all outstanding data from the connection.
long	generateChannelID()	generate a unique (within this connection) channel id
long	getBlockingCallFailoverTimeout()	Returns the current timeout for blocking calls.
long	getBlockingCallTimeout()	Returns the current timeout for blocking calls).
Channel	getChannel(long channelID, int confWindowSize)	Returns the channel with the channel id specified.
int	getChannelVersion()	The client protocol used on the communication.
ActiveMQPrincipal	getDefaultActiveMQPrincipal()	Returns the default security principal.
long	getIDGeneratorSequence()	Returns the next id to be chosen.
List<Interceptor>	getIncomingInterceptors()
List<Interceptor>	getOutgoingInterceptors()
String	getProtocolName()	Returns the name of the protocol for this Remoting Connection.
Object	getTransferLock()	Returns the transfer lock used when transferring connections.
boolean	isClient()	Returns true if the RemotingConnection is a client, otherwise false.
boolean	isSupportReconnect()	This will check if reconnects are supported on the protocol and configuration.
boolean	isSupportsFlowControl()	Return true if the protocol supports flow control.
void	killMessage(SimpleString nodeID)	if slow consumer is killed,send the msessage to client.
void	putChannel(long channelID, Channel channel)	add the channel with the specified channel id
protected void	removeAllChannels()
boolean	removeChannel(long channelID)	remove the channel with the specified channel id
void	setChannelVersion(int clientVersion)	Sets the client protocol used on the communication.
void	syncIDGeneratorSequence(long id)	Resets the id generator used to generate id's.
String	toString()

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

addCloseListener, addFailureListener, asyncFail, callClosingListeners, callFailureListeners, checkDataReceived, createTransportBuffer, fail, getClientID, getCreationTime, getFailureListeners, getID, getLocalAddress, getRemoteAddress, getSubject, getTransportConnection, getTransportLocalAddress, isDestroyed, isWritable, removeCloseListener, removeCloseListeners, removeFailureListener, removeFailureListeners, scheduledFlush, setClientID, setCloseListeners, setFailureListeners, setSubject

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.activemq.artemis.core.protocol.core.CoreRemotingConnection

isBeforeProducerMetricsChanged, isBeforeTwoEighteen, isVersionBeforeAddressChange, isVersionBeforeAsyncResponseChange, isVersionNewFQQN, isVersionSupportClientID, isVersionSupportCommitV2, isVersionSupportConsumerPriority, isVersionSupportRouting, isVersionUsingLongOnPageReplication

Methods inherited from interface org.apache.activemq.artemis.spi.core.protocol.RemotingConnection

addCloseListener, addFailureListener, asyncFail, checkDataReceived, createTransportBuffer, fail, getClientID, getCreationTime, getFailureListeners, getID, getRemoteAddress, getSubject, getTransportConnection, getTransportLocalAddress, isDestroyed, isSameTarget, isWritable, removeCloseListener, removeCloseListeners, removeFailureListener, removeFailureListeners, scheduledFlush, setClientID, setCloseListeners, setFailureListeners, setSubject

Constructor Details

RemotingConnectionImpl

public RemotingConnectionImpl(PacketDecoder packetDecoder,
 Connection transportConnection,
 long blockingCallTimeout,
 long blockingCallFailoverTimeout,
 List<Interceptor> incomingInterceptors,
 List<Interceptor> outgoingInterceptors,
 Executor connectionExecutor)

Create a client side connection

RemotingConnectionImpl

public RemotingConnectionImpl(PacketDecoder packetDecoder,
 Connection transportConnection,
 List<Interceptor> incomingInterceptors,
 List<Interceptor> outgoingInterceptors,
 SimpleString nodeID,
 Executor connectionExecutor)

Create a server side connection

Method Details

toString

public String toString()

Overrides:

toString in class Object

getChannelVersion

public int getChannelVersion()

Description copied from interface: CoreRemotingConnection

The client protocol used on the communication. This will determine if the client has support for certain packet types

Specified by:

getChannelVersion in interface CoreRemotingConnection

setChannelVersion

public void setChannelVersion(int clientVersion)

Description copied from interface: CoreRemotingConnection

Sets the client protocol used on the communication. This will determine if the client has support for certain packet types

Specified by:

setChannelVersion in interface CoreRemotingConnection

getChannel

public Channel getChannel(long channelID,
 int confWindowSize)

Description copied from interface: CoreRemotingConnection

Returns the channel with the channel id specified.

If it does not exist create it with the confirmation window size.

Specified by:

getChannel in interface CoreRemotingConnection

Parameters:

channelID - the channel id

confWindowSize - the confirmation window size

Returns:

the channel

removeChannel

public boolean removeChannel(long channelID)

Description copied from interface: CoreRemotingConnection

remove the channel with the specified channel id

Specified by:

removeChannel in interface CoreRemotingConnection

Parameters:

channelID - the channel id

Returns:

true if removed

putChannel

public void putChannel(long channelID,
 Channel channel)

Description copied from interface: CoreRemotingConnection

add the channel with the specified channel id

Specified by:

putChannel in interface CoreRemotingConnection

Parameters:

channelID - the channel id

channel - the channel

getIncomingInterceptors

public List<Interceptor> getIncomingInterceptors()

getOutgoingInterceptors

public List<Interceptor> getOutgoingInterceptors()

fail

public void fail(ActiveMQException me,
 String scaleDownTargetNodeID)

Description copied from interface: RemotingConnection

called when the underlying connection fails.

Specified by:

fail in interface RemotingConnection

Parameters:

me - the exception that caused the failure

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

close

public void close()

Specified by:

close in interface RemotingConnection

Overrides:

close in class AbstractRemotingConnection

destroy

public void destroy()

Description copied from interface: RemotingConnection

destroys this connection.

Specified by:

destroy in interface RemotingConnection

blockUntilWritable

public boolean blockUntilWritable(long timeout)

Description copied from interface: CoreRemotingConnection

Specified by:

blockUntilWritable in interface CoreRemotingConnection

disconnect

public void disconnect(boolean criticalError)

Description copied from interface: RemotingConnection

Disconnect the connection, closing all channels

Specified by:

disconnect in interface RemotingConnection

disconnect

public void disconnect(String scaleDownNodeID,
 boolean criticalError)

Description copied from interface: RemotingConnection

Disconnect the connection, closing all channels

Specified by:

disconnect in interface RemotingConnection

disconnect

public void disconnect(DisconnectReason reason,
 String targetNodeID,
 TransportConfiguration targetConnector)

Description copied from interface: RemotingConnection

Disconnect the connection, closing all channels

Specified by:

disconnect in interface RemotingConnection

generateChannelID

public long generateChannelID()

Description copied from interface: CoreRemotingConnection

generate a unique (within this connection) channel id

Specified by:

generateChannelID in interface CoreRemotingConnection

Returns:

the id

syncIDGeneratorSequence

public void syncIDGeneratorSequence(long id)

Description copied from interface: CoreRemotingConnection

Resets the id generator used to generate id's.

Specified by:

syncIDGeneratorSequence in interface CoreRemotingConnection

Parameters:

id - the first id to set it to

getIDGeneratorSequence

public long getIDGeneratorSequence()

Description copied from interface: CoreRemotingConnection

Returns the next id to be chosen.

Specified by:

getIDGeneratorSequence in interface CoreRemotingConnection

Returns:

the next id to be chosen

getTransferLock

public Object getTransferLock()

Description copied from interface: CoreRemotingConnection

Returns the transfer lock used when transferring connections.

Specified by:

getTransferLock in interface CoreRemotingConnection

Returns:

the transfer lock used when transferring connections

isClient

public boolean isClient()

Description copied from interface: RemotingConnection

Returns true if the RemotingConnection is a client, otherwise false.

Specified by:

isClient in interface RemotingConnection

Overrides:

isClient in class AbstractRemotingConnection

Returns:

true if the RemotingConnection is a client, otherwise false

getBlockingCallTimeout

public long getBlockingCallTimeout()

Description copied from interface: CoreRemotingConnection

Returns the current timeout for blocking calls).

Specified by:

getBlockingCallTimeout in interface CoreRemotingConnection

Returns:

the current timeout for blocking calls)

getBlockingCallFailoverTimeout

public long getBlockingCallFailoverTimeout()

Description copied from interface: CoreRemotingConnection

Returns the current timeout for blocking calls.

Specified by:

getBlockingCallFailoverTimeout in interface CoreRemotingConnection

Returns:

the current timeout for blocking calls

flush

public void flush()

Description copied from interface: RemotingConnection

flush all outstanding data from the connection.

Specified by:

flush in interface RemotingConnection

Overrides:

flush in class AbstractRemotingConnection

getDefaultActiveMQPrincipal

public ActiveMQPrincipal getDefaultActiveMQPrincipal()

Description copied from interface: CoreRemotingConnection

Returns the default security principal.

Specified by:

getDefaultActiveMQPrincipal in interface CoreRemotingConnection

Returns:

the default security principal

isSupportReconnect

public boolean isSupportReconnect()

Description copied from interface: RemotingConnection

This will check if reconnects are supported on the protocol and configuration. In case it's not supported a connection failure could remove messages right away from pending deliveries.

Specified by:

isSupportReconnect in interface RemotingConnection

Overrides:

isSupportReconnect in class AbstractRemotingConnection

isSupportsFlowControl

public boolean isSupportsFlowControl()

Description copied from interface: RemotingConnection

Return true if the protocol supports flow control. This is because in some cases we may need to hold message producers in cases like disk full. If the protocol doesn't support it we trash the connection and throw exceptions.

Specified by:

isSupportsFlowControl in interface RemotingConnection

Overrides:

isSupportsFlowControl in class AbstractRemotingConnection

getProtocolName

public String getProtocolName()

Description copied from interface: RemotingConnection

Returns the name of the protocol for this Remoting Connection.

Specified by:

getProtocolName in interface RemotingConnection

Returns:

the name of the protocol for this Remoting 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

endOfBatch

public void endOfBatch(Object connectionID)

Specified by:

endOfBatch in interface BufferHandler

removeAllChannels

protected void removeAllChannels()

killMessage

public void killMessage(SimpleString nodeID)

Description copied from interface: RemotingConnection

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

Specified by:

killMessage in interface RemotingConnection

Overrides:

killMessage in class AbstractRemotingConnection