public interface ProtonSession
| Modifier and Type | Method and Description |
|---|---|
org.apache.qpid.proton.engine.Record |
attachments()
Retrieves the attachments record, upon which application items can be set/retrieved.
|
ProtonSession |
close()
Closed the AMQP session, i.e.
|
ProtonSession |
closeHandler(Handler<AsyncResult<ProtonSession>> remoteCloseHandler)
Sets a handler for when an AMQP End frame is received from the remote peer.
|
ProtonReceiver |
createReceiver(String address)
Creates a receiver used to consumer messages from the given node address.
|
ProtonSender |
createSender(String address)
Creates a sender used to send messages to the given node address.
|
org.apache.qpid.proton.amqp.transport.ErrorCondition |
getCondition()
Gets the local ErrorCondition object.
|
int |
getIncomingCapacity()
Gets the incoming capacity in bytes, used to govern session-level flow control.
|
org.apache.qpid.proton.amqp.transport.ErrorCondition |
getRemoteCondition()
Gets the remote ErrorCondition object.
|
ProtonSession |
open()
Opens the AMQP session, i.e.
|
ProtonSession |
openHandler(Handler<AsyncResult<ProtonSession>> remoteOpenHandler)
Sets a handler for when an AMQP Begin frame is received from the remote peer.
|
ProtonSession |
setCondition(org.apache.qpid.proton.amqp.transport.ErrorCondition condition)
Sets the local ErrorCondition object.
|
ProtonSession |
setIncomingCapacity(int capacity)
Sets the incoming capacity in bytes, used to govern session-level flow control.
|
ProtonReceiver createReceiver(String address)
address - The source address to attach the consumer to.ProtonSender createSender(String address)
address - The target address to attach to, or null to attach to the anonymous relay.ProtonSession open()
openHandler(Handler) may be used to handle the peer sending their
Begin frame.ProtonSession close()
closeHandler(Handler) may be used to handle the peer
sending their End frame.org.apache.qpid.proton.engine.Record attachments()
ProtonSession setIncomingCapacity(int capacity)
capacity - capacity in bytesint getIncomingCapacity()
ProtonSession setCondition(org.apache.qpid.proton.amqp.transport.ErrorCondition condition)
condition - the condition to setorg.apache.qpid.proton.amqp.transport.ErrorCondition getCondition()
org.apache.qpid.proton.amqp.transport.ErrorCondition getRemoteCondition()
ProtonSession openHandler(Handler<AsyncResult<ProtonSession>> remoteOpenHandler)
ProtonConnection.sessionOpenHandler(Handler).remoteOpenHandler - the handlerProtonSession closeHandler(Handler<AsyncResult<ProtonSession>> remoteCloseHandler)
remoteCloseHandler - the handlerCopyright © 2016. All rights reserved.