ProtonSessionImpl

@author <a href="http://hiramchirino.com">Hiram Chirino</a>

Constructors

this
this(Session session)
Undocumented in source.

Members

Functions

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.

Inherited Members

From ProtonSession

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.

Meta