- attachments
Record attachments()
Undocumented in source. Be warned that the author may not have intended to support it.
- close
ProtonSessionImpl close()
Undocumented in source. Be warned that the author may not have intended to support it.
- closeHandler
ProtonSessionImpl closeHandler(Handler!ProtonSession closeHandler)
Undocumented in source. Be warned that the author may not have intended to support it.
- createReceiver
ProtonReceiver createReceiver(string address)
Undocumented in source. Be warned that the author may not have intended to support it.
- createReceiver
ProtonReceiver createReceiver(string address, ProtonLinkOptions receiverOptions)
Undocumented in source. Be warned that the author may not have intended to support it.
- createSender
ProtonSender createSender(string address)
Undocumented in source. Be warned that the author may not have intended to support it.
- createSender
ProtonSender createSender(string address, ProtonLinkOptions senderOptions)
Undocumented in source. Be warned that the author may not have intended to support it.
- fireRemoteClose
void fireRemoteClose()
Undocumented in source. Be warned that the author may not have intended to support it.
- fireRemoteOpen
void fireRemoteOpen()
//////////////////////////////////////////////////////////////////////////
//////////////////////////////////////////////////////////////////////////
- free
void free()
Undocumented in source. Be warned that the author may not have intended to support it.
- getCondition
ErrorCondition getCondition()
Undocumented in source. Be warned that the author may not have intended to support it.
- getConnection
ProtonConnection getConnection()
Undocumented in source. Be warned that the author may not have intended to support it.
- getConnectionImpl
ProtonConnectionImpl getConnectionImpl()
Undocumented in source. Be warned that the author may not have intended to support it.
- getIncomingBytes
int getIncomingBytes()
Undocumented in source. Be warned that the author may not have intended to support it.
- getIncomingCapacity
int getIncomingCapacity()
Undocumented in source. Be warned that the author may not have intended to support it.
- getLocalState
EndpointState getLocalState()
Undocumented in source. Be warned that the author may not have intended to support it.
- getOutgoingBytes
int getOutgoingBytes()
Undocumented in source. Be warned that the author may not have intended to support it.
- getOutgoingWindow
long getOutgoingWindow()
Undocumented in source. Be warned that the author may not have intended to support it.
- getRemoteCondition
ErrorCondition getRemoteCondition()
Undocumented in source. Be warned that the author may not have intended to support it.
- getRemoteState
EndpointState getRemoteState()
Undocumented in source. Be warned that the author may not have intended to support it.
- open
ProtonSessionImpl open()
Undocumented in source. Be warned that the author may not have intended to support it.
- openHandler
ProtonSessionImpl openHandler(Handler!ProtonSession openHandler)
Undocumented in source. Be warned that the author may not have intended to support it.
- setCondition
ProtonSession setCondition(ErrorCondition condition)
Undocumented in source. Be warned that the author may not have intended to support it.
- setIncomingCapacity
ProtonSession setIncomingCapacity(int bytes)
Undocumented in source. Be warned that the author may not have intended to support it.
- setOutgoingWindow
void setOutgoingWindow(long outgoingWindowSize)
Undocumented in source. Be warned that the author may not have intended to support it.
- createReceiver
ProtonReceiver createReceiver(string address)
Creates a receiver used to consumer messages from the given node address.
- createReceiver
ProtonReceiver createReceiver(string address, ProtonLinkOptions receiverOptions)
Creates a receiver used to consumer messages from the given node address.
- createSender
ProtonSender createSender(string address)
Creates a sender used to send messages to the given node address. If no address (i.e null) is specified then a
sender will be established to the 'anonymous relay' and each message must specify its destination address.
- createSender
ProtonSender createSender(string address, ProtonLinkOptions senderOptions)
Creates a sender used to send messages to the given node address. If no address (i.e null) is specified then a
sender will be established to the 'anonymous relay' and each message must specify its destination address.
- open
ProtonSession open()
Opens the AMQP session, i.e. allows the Begin frame to be emitted. Typically used after any additional
configuration is performed on the object.
- close
ProtonSession close()
Closed the AMQP session, i.e. allows the End frame to be emitted.
- attachments
Record attachments()
Retrieves the attachments record, upon which application items can be set/retrieved.
- setIncomingCapacity
ProtonSession setIncomingCapacity(int capacity)
Sets the incoming capacity in bytes, used to govern session-level flow control.
- getIncomingCapacity
int getIncomingCapacity()
Gets the incoming capacity in bytes, used to govern session-level flow control.
- getConnection
ProtonConnection getConnection()
Gets the connection this session is on.
- setCondition
ProtonSession setCondition(ErrorCondition condition)
Sets the local ErrorCondition object.
- getCondition
ErrorCondition getCondition()
Gets the local ErrorCondition object.
- getRemoteCondition
ErrorCondition getRemoteCondition()
Gets the remote ErrorCondition object.
- openHandler
ProtonSession openHandler(Handler!ProtonSession remoteOpenHandler)
Sets a handler for when an AMQP Begin frame is received from the remote peer.
- closeHandler
ProtonSession closeHandler(Handler!ProtonSession remoteCloseHandler)
Sets a handler for when an AMQP End frame is received from the remote peer.
- free
void free()
Tidies up related session resources when complete with use. Call only after the
session is finished with, i.e. locally and remotely closed.
@author <a href="http://hiramchirino.com">Hiram Chirino</a>