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

Class AbstractRemotingConnection

java.lang.Object

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

All Implemented Interfaces:

RemotingConnection, BufferHandler

public abstract class AbstractRemotingConnection
extends Object
implements RemotingConnection

Field Summary

Fields

Modifier and Type	Field	Description
protected final List<org.apache.activemq.artemis.core.remoting.CloseListener>	closeListeners
protected final long	creationTime
protected boolean	dataReceived
protected boolean	destroyed
protected final Executor	executor
protected final List<org.apache.activemq.artemis.core.remoting.FailureListener>	failureListeners
protected final Connection	transportConnection

Constructor Summary

Constructors

Constructor	Description
AbstractRemotingConnection(Connection transportConnection, Executor executor)

Method Summary

Modifier and Type	Method	Description
void	addCloseListener(org.apache.activemq.artemis.core.remoting.CloseListener listener)	add a CloseListener.
void	addFailureListener(org.apache.activemq.artemis.core.remoting.FailureListener listener)	add a failure listener.
Future	asyncFail(ActiveMQException me)	Same thing as fail, but using an executor. semantic of send here, is asynchrounous.
void	bufferReceived(Object connectionID, ActiveMQBuffer buffer)	called by the remoting connection when a buffer is received.
protected void	callClosingListeners()
protected void	callFailureListeners(ActiveMQException me, String scaleDownTargetNodeID)
boolean	checkDataReceived()	Returns true if any data has been received since the last time this method was called.
void	close()
ActiveMQBuffer	createTransportBuffer(int size)	creates a new ActiveMQBuffer of the specified size.
void	fail(ActiveMQException me)	called when the underlying connection fails.
void	flush()	flush all outstanding data from the connection.
String	getClientID()	Returns the Client ID associated with this connection.
long	getCreationTime()	Returns the creation time of the RemotingConnection.
List<org.apache.activemq.artemis.core.remoting.FailureListener>	getFailureListeners()	Returns all the failure listeners.
Object	getID()	Returns the unique id of the RemotingConnection.
String	getLocalAddress()
String	getRemoteAddress()	Returns a string representation of the remote address of this connection.
Subject	getSubject()	the possibly null subject associated with this connection
Connection	getTransportConnection()	return the underlying Connection.
String	getTransportLocalAddress()	Returns a string representation of the local address this connection is connected to This is useful when the server is configured at 0.0.0.0 (or multiple IPs).
boolean	isClient()	Returns true if the RemotingConnection is a client, otherwise false.
boolean	isDestroyed()	Returns true if this RemotingConnection has been destroyed, 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.
boolean	isWritable(ReadyListener callback)
void	killMessage(SimpleString nodeID)	if slow consumer is killed,send the msessage to client.
boolean	removeCloseListener(org.apache.activemq.artemis.core.remoting.CloseListener listener)	remove a Close Listener
List<org.apache.activemq.artemis.core.remoting.CloseListener>	removeCloseListeners()
boolean	removeFailureListener(org.apache.activemq.artemis.core.remoting.FailureListener listener)	remove the failure listener
List<org.apache.activemq.artemis.core.remoting.FailureListener>	removeFailureListeners()
void	scheduledFlush()
void	setClientID(String clientId)	Sets the client ID associated with this connection
void	setCloseListeners(List<org.apache.activemq.artemis.core.remoting.CloseListener> listeners)
void	setFailureListeners(List<org.apache.activemq.artemis.core.remoting.FailureListener> listeners)	set the failure listeners.
void	setSubject(Subject subject)	sets the currently associated subject for this connection

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.activemq.artemis.spi.core.remoting.BufferHandler

endOfBatch

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

destroy, disconnect, disconnect, disconnect, fail, getProtocolName, isSameTarget

Field Details

failureListeners

protected final List<org.apache.activemq.artemis.core.remoting.FailureListener> failureListeners

closeListeners

protected final List<org.apache.activemq.artemis.core.remoting.CloseListener> closeListeners

transportConnection

protected final Connection transportConnection

executor

protected final Executor executor

creationTime

protected final long creationTime

destroyed

protected volatile boolean destroyed

dataReceived

protected volatile boolean dataReceived

Constructor Details

AbstractRemotingConnection

public AbstractRemotingConnection(Connection transportConnection,
 Executor executor)

Method Details

scheduledFlush

public void scheduledFlush()

Specified by:

scheduledFlush in interface RemotingConnection

getFailureListeners

public List<org.apache.activemq.artemis.core.remoting.FailureListener> getFailureListeners()

Description copied from interface: RemotingConnection

Returns all the failure listeners.

Specified by:

getFailureListeners in interface RemotingConnection

Returns:

all the failure listeners

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

Returns:

true if the RemotingConnection is a client, otherwise false

isDestroyed

public boolean isDestroyed()

Description copied from interface: RemotingConnection

Returns true if this RemotingConnection has been destroyed, otherwise false.

Specified by:

isDestroyed in interface RemotingConnection

Returns:

true if this RemotingConnection has been destroyed, otherwise false

flush

public void flush()

Description copied from interface: RemotingConnection

flush all outstanding data from the connection.

Specified by:

flush in interface RemotingConnection

isWritable

public boolean isWritable(ReadyListener callback)

Specified by:

isWritable in interface RemotingConnection

callFailureListeners

protected void callFailureListeners(ActiveMQException me,
 String scaleDownTargetNodeID)

callClosingListeners

protected void callClosingListeners()

setFailureListeners

public void setFailureListeners(List<org.apache.activemq.artemis.core.remoting.FailureListener> listeners)

Description copied from interface: RemotingConnection

set the failure listeners.

These will be called in the event of the connection being closed. Any previously added listeners will be removed.

Specified by:

setFailureListeners in interface RemotingConnection

Parameters:

listeners - the listeners to add.

getID

public Object getID()

Description copied from interface: RemotingConnection

Returns the unique id of the RemotingConnection.

Specified by:

getID in interface RemotingConnection

Returns:

the unique id of the RemotingConnection

getLocalAddress

public String getLocalAddress()

getRemoteAddress

public String getRemoteAddress()

Description copied from interface: RemotingConnection

Returns a string representation of the remote address of this connection.

Specified by:

getRemoteAddress in interface RemotingConnection

Returns:

a string representation of the remote address of this connection

addFailureListener

public void addFailureListener(org.apache.activemq.artemis.core.remoting.FailureListener listener)

Description copied from interface: RemotingConnection

add a failure listener.

The listener will be called in the event of connection failure.

Specified by:

addFailureListener in interface RemotingConnection

Parameters:

listener - the listener

removeFailureListener

public boolean removeFailureListener(org.apache.activemq.artemis.core.remoting.FailureListener listener)

Description copied from interface: RemotingConnection

remove the failure listener

Specified by:

removeFailureListener in interface RemotingConnection

Parameters:

listener - the lister to remove

Returns:

true if removed

addCloseListener

public void addCloseListener(org.apache.activemq.artemis.core.remoting.CloseListener listener)

Description copied from interface: RemotingConnection

add a CloseListener.

This will be called in the event of the connection being closed.

Specified by:

addCloseListener in interface RemotingConnection

Parameters:

listener - the listener to add

removeCloseListener

public boolean removeCloseListener(org.apache.activemq.artemis.core.remoting.CloseListener listener)

Description copied from interface: RemotingConnection

remove a Close Listener

Specified by:

removeCloseListener in interface RemotingConnection

Parameters:

listener - the listener to remove

Returns:

true if removed

removeCloseListeners

public List<org.apache.activemq.artemis.core.remoting.CloseListener> removeCloseListeners()

Specified by:

removeCloseListeners in interface RemotingConnection

removeFailureListeners

public List<org.apache.activemq.artemis.core.remoting.FailureListener> removeFailureListeners()

Specified by:

removeFailureListeners in interface RemotingConnection

setCloseListeners

public void setCloseListeners(List<org.apache.activemq.artemis.core.remoting.CloseListener> listeners)

Specified by:

setCloseListeners in interface RemotingConnection

createTransportBuffer

public ActiveMQBuffer createTransportBuffer(int size)

Description copied from interface: RemotingConnection

creates a new ActiveMQBuffer of the specified size. For the purpose of i/o outgoing packets

Specified by:

createTransportBuffer in interface RemotingConnection

Parameters:

size - the size of buffer required

Returns:

the buffer

getTransportConnection

public Connection getTransportConnection()

Description copied from interface: RemotingConnection

return the underlying Connection.

Specified by:

getTransportConnection in interface RemotingConnection

Returns:

the connection

getCreationTime

public long getCreationTime()

Description copied from interface: RemotingConnection

Returns the creation time of the RemotingConnection.

Specified by:

getCreationTime in interface RemotingConnection

Returns:

the creation time of the RemotingConnection

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

Returns:

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

fail

public void fail(ActiveMQException me)

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

close

public void close()

Specified by:

close in interface RemotingConnection

asyncFail

public Future asyncFail(ActiveMQException me)

Description copied from interface: RemotingConnection

Same thing as fail, but using an executor. semantic of send here, is asynchrounous.

Specified by:

asyncFail in interface RemotingConnection

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

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.

Specified by:

killMessage in interface RemotingConnection

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

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

setSubject

public void setSubject(Subject subject)

Description copied from interface: RemotingConnection

sets the currently associated subject for this connection

Specified by:

setSubject in interface RemotingConnection

getSubject

public Subject getSubject()

Description copied from interface: RemotingConnection

the possibly null subject associated with this connection

Specified by:

getSubject in interface RemotingConnection

setClientID

public void setClientID(String clientId)

Description copied from interface: RemotingConnection

Sets the client ID associated with this connection

Specified by:

setClientID in interface RemotingConnection

getClientID

public String getClientID()

Description copied from interface: RemotingConnection

Returns the Client ID associated with this connection.

Specified by:

getClientID in interface RemotingConnection

Returns:

the Client ID associated with this connection

getTransportLocalAddress

public String getTransportLocalAddress()

Description copied from interface: RemotingConnection

Returns a string representation of the local address this connection is connected to This is useful when the server is configured at 0.0.0.0 (or multiple IPs). This will give you the actual IP that's being used.

Specified by:

getTransportLocalAddress in interface RemotingConnection

Returns:

the local address of transport connection