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 and Description
boolean	blockUntilWritable(int size, 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	getClientVersion() 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.
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	setClientVersion(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.protocol.RemotingConnection

addCloseListener, addFailureListener, checkDataReceived, createTransportBuffer, destroy, disconnect, disconnect, fail, fail, flush, getCreationTime, getFailureListeners, getID, getRemoteAddress, getTransportConnection, isClient, isDestroyed, isSupportReconnect, isSupportsFlowControl, isWritable, killMessage, removeCloseListener, removeCloseListeners, removeFailureListener, removeFailureListeners, setCloseListeners, setFailureListeners

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

bufferReceived

Method Detail

getClientVersion

int getClientVersion()

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

setClientVersion

void setClientVersion(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(int size,
                           long timeout)

Parameters:

size - size we are trying to write

timeout -

Returns:

Throws:

IllegalStateException - if the connection is closed