public interface CoreRemotingConnection extends RemotingConnection
Modifier and Type | Method and Description |
---|---|
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.
|
HornetQPrincipal |
getDefaultHornetQPrincipal()
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.
|
addCloseListener, addFailureListener, checkDataReceived, createBuffer, destroy, disconnect, fail, flush, getCreationTime, getFailureListeners, getID, getRemoteAddress, getTransportConnection, isClient, isDestroyed, removeCloseListener, removeCloseListeners, removeFailureListener, removeFailureListeners, setCloseListeners, setFailureListeners
bufferReceived
int getClientVersion()
void setClientVersion(int clientVersion)
Channel getChannel(long channelID, int confWindowSize)
If it does not exist create it with the confirmation window size.
channelID
- the channel idconfWindowSize
- the confirmation window sizevoid putChannel(long channelID, Channel channel)
channelID
- the channel idchannel
- the channelboolean removeChannel(long channelID)
channelID
- the channel idlong generateChannelID()
void syncIDGeneratorSequence(long id)
id
- the first id to set it tolong getIDGeneratorSequence()
long getBlockingCallTimeout()
long getBlockingCallFailoverTimeout()
Object getTransferLock()
HornetQPrincipal getDefaultHornetQPrincipal()
Copyright © 2018 JBoss by Red Hat. All rights reserved.