|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface AMQProtocolSession
Method Summary | |
---|---|
void |
addChannel(AMQChannel channel)
Associate a channel with this session. |
void |
closeChannel(int channelId)
Close a specific channel. |
void |
closeSession()
This must be called when the session is _closed in order to free up any resources managed by the session. |
void |
dataBlockReceived(org.apache.qpid.framing.AMQDataBlock message)
Called when a protocol data block is received |
AMQChannel |
getChannel(int channelId)
Get the channel for this session associated with the specified id. |
java.lang.String |
getContextKey()
Get the context key associated with this session. |
java.lang.Object |
getKey()
|
java.lang.String |
getLocalFQDN()
Get the fully qualified domain name of the local address to which this session is bound. |
javax.security.sasl.SaslServer |
getSaslServer()
|
void |
initHeartbeats(int delay)
Initialise heartbeats on the session. |
void |
removeChannel(int channelId)
Remove a channel from the session but do not close it. |
void |
setContextKey(java.lang.String contextKey)
Set the context key associated with this session. |
void |
setSaslServer(javax.security.sasl.SaslServer saslServer)
Set the sasl server that is to perform authentication for this session. |
void |
writeFrame(org.apache.qpid.framing.AMQDataBlock frame)
Write a datablock, encoding where necessary (e.g. |
Method Detail |
---|
void dataBlockReceived(org.apache.qpid.framing.AMQDataBlock message) throws java.lang.Exception
message
- the data block that has been received
java.lang.Exception
- if processing the datablock failsvoid writeFrame(org.apache.qpid.framing.AMQDataBlock frame)
frame
- the frame to be encoded and writtenjava.lang.String getContextKey()
void setContextKey(java.lang.String contextKey)
contextKey
- the context keyAMQChannel getChannel(int channelId) throws org.apache.qpid.AMQException
channelId
- the channel id which must be valid
org.apache.qpid.AMQException
void addChannel(AMQChannel channel)
channel
- the channel to associate with this session. It is an error to
associate the same channel with more than one session but this is not validated.void closeChannel(int channelId) throws org.apache.qpid.AMQException
channelId
- id of the channel to close
org.apache.qpid.AMQException
- if an error occurs closing the channel
java.lang.IllegalArgumentException
- if the channel id is not validvoid removeChannel(int channelId)
channelId
- void initHeartbeats(int delay)
delay
- delay in seconds (not ms)void closeSession() throws org.apache.qpid.AMQException
org.apache.qpid.AMQException
java.lang.Object getKey()
java.lang.String getLocalFQDN()
javax.security.sasl.SaslServer getSaslServer()
void setSaslServer(javax.security.sasl.SaslServer saslServer)
saslServer
-
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |