org.hornetq.core.protocol.core

Interface CoreRemotingConnection

All Superinterfaces:

BufferHandler, RemotingConnection

All Known Implementing Classes:

RemotingConnectionImpl

public interface CoreRemotingConnection
extends RemotingConnection

Extension of RemotingConnection for the HornetQ core protocol

Author:

Tim Fox

Method Summary

Methods

Modifier and Type	Method and Description
void	checkFlushBatchBuffer() Called periodically to flush any data in the batch buffer
long	generateChannelID() generate a unique (within this connection) channel id
long	getBlockingCallTimeout() return the current tomeout for blocking calls
Channel	getChannel(long channelID, int confWindowSize) return the channel with the channel id specified.
int	getClientVersion() The client protocol used on the communication.
HornetQPrincipal	getDefaultHornetQPrincipal() get the default security principal for invm
long	getIDGeneratorSequence() return the next id that will be chosen.
Object	getTransferLock() return 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) The client protocol used on the communication.
void	syncIDGeneratorSequence(long id) resets the id generator used to when generating id's

Methods inherited from interface org.hornetq.spi.core.protocol.RemotingConnection

addCloseListener, addFailureListener, checkDataReceived, createBuffer, destroy, disconnect, fail, flush, getCreationTime, getFailureListeners, getID, getRemoteAddress, getTransportConnection, isClient, isDestroyed, removeCloseListener, removeCloseListeners, removeFailureListener, removeFailureListeners, setCloseListeners, setFailureListeners

Methods inherited from interface org.hornetq.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)

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)

return 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 when generating id's

Parameters:

id - the first id to set it to

getIDGeneratorSequence

long getIDGeneratorSequence()

return the next id that will be chosen.

Returns:

the id

getBlockingCallTimeout

long getBlockingCallTimeout()

return the current tomeout for blocking calls

Returns:

the timeout in milliseconds

getTransferLock

Object getTransferLock()

return the transfer lock used when transferring connections.

Returns:

the lock

checkFlushBatchBuffer

void checkFlushBatchBuffer()

Called periodically to flush any data in the batch buffer

getDefaultHornetQPrincipal

HornetQPrincipal getDefaultHornetQPrincipal()

get the default security principal for invm

Returns:

the principal