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

Interface CoreRemotingConnection

All Superinterfaces:

BufferHandler, RemotingConnection

All Known Implementing Classes:

RemotingConnectionImpl

public interface CoreRemotingConnection
extends RemotingConnection

Extension of RemotingConnection for the ActiveMQ Artemis core protocol

Method Summary

Modifier and Type	Method	Description
boolean	blockUntilWritable(long timeout)
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.
Object	getTransferLock()	Returns the transfer lock used when transferring connections.
default boolean	isBeforeTwoEighteen()
default boolean	isVersionBeforeAddressChange()
default boolean	isVersionBeforeAsyncResponseChange()
default boolean	isVersionNewFQQN()
default boolean	isVersionSupportClientID()
default boolean	isVersionSupportCommitV2()
default boolean	isVersionSupportConsumerPriority()
default boolean	isVersionSupportRouting()
void	putChannel(long channelID, Channel channel)	add the channel with the specified channel id
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.

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

bufferReceived, endOfBatch

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

addCloseListener, addFailureListener, asyncFail, checkDataReceived, createTransportBuffer, destroy, disconnect, disconnect, disconnect, fail, fail, flush, getAuditSubject, getClientID, getCreationTime, getFailureListeners, getID, getProtocolName, getRemoteAddress, getSubject, getTransportConnection, getTransportLocalAddress, isClient, isDestroyed, isSameTarget, isSupportReconnect, isSupportsFlowControl, isWritable, killMessage, removeCloseListener, removeCloseListeners, removeFailureListener, removeFailureListeners, scheduledFlush, setAuditSubject, setClientID, setCloseListeners, setFailureListeners

Method Detail

getChannelVersion

int getChannelVersion()

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

isVersionBeforeAddressChange

default boolean isVersionBeforeAddressChange()

isVersionBeforeAsyncResponseChange

default boolean isVersionBeforeAsyncResponseChange()

isVersionSupportConsumerPriority

default boolean isVersionSupportConsumerPriority()

isVersionNewFQQN

default boolean isVersionNewFQQN()

isVersionSupportClientID

default boolean isVersionSupportClientID()

isVersionSupportRouting

default boolean isVersionSupportRouting()

isVersionSupportCommitV2

default boolean isVersionSupportCommitV2()

isBeforeTwoEighteen

default boolean isBeforeTwoEighteen()

setChannelVersion

void setChannelVersion(int clientVersion)

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

getChannel

Channel getChannel(long channelID,
                   int confWindowSize)

Returns the channel with the channel id specified.

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

Parameters:

channelID - the channel id

confWindowSize - the confirmation window size

Returns:

the channel

putChannel

void putChannel(long channelID,
                Channel channel)

add the channel with the specified channel id

Parameters:

channelID - the channel id

channel - the channel

removeChannel

boolean removeChannel(long channelID)

remove the channel with the specified channel id

Parameters:

channelID - the channel id

Returns:

true if removed

generateChannelID

long generateChannelID()

generate a unique (within this connection) channel id

Returns:

the id

syncIDGeneratorSequence

void syncIDGeneratorSequence(long id)

Resets the id generator used to generate id's.

Parameters:

id - the first id to set it to

getIDGeneratorSequence

long getIDGeneratorSequence()

Returns the next id to be chosen.

Returns:

the id

getBlockingCallTimeout

long getBlockingCallTimeout()

Returns the current timeout for blocking calls

Returns:

the timeout in milliseconds

getBlockingCallFailoverTimeout

long getBlockingCallFailoverTimeout()

Returns the current timeout for blocking calls

Returns:

the timeout in milliseconds

getTransferLock

Object getTransferLock()

Returns the transfer lock used when transferring connections.

Returns:

the lock

getDefaultActiveMQPrincipal

ActiveMQPrincipal getDefaultActiveMQPrincipal()

Returns the default security principal

Returns:

the principal

blockUntilWritable

boolean blockUntilWritable(long timeout)

Parameters:

timeout -

Returns:

Throws:

IllegalStateException - if the connection is closed