ProtonConnectionImpl

addEndHandler void addEndHandler(Handler!Void handler): Undocumented in source. Be warned that the author may not have intended to support it.
attachments Record attachments(): Undocumented in source. Be warned that the author may not have intended to support it.
bindClient void bindClient(NetClient client, ProtonSaslClientAuthenticatorImpl authenticator, ProtonTransportOptions transportOptions): Undocumented in source. Be warned that the author may not have intended to support it.
close ProtonConnection close(): Undocumented in source. Be warned that the author may not have intended to support it.
closeHandler ProtonConnection closeHandler(AsyncResultHandler!ProtonConnection 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.
createSession ProtonSessionImpl createSession(): Undocumented in source. Be warned that the author may not have intended to support it.
disconnect void disconnect(): Undocumented in source. Be warned that the author may not have intended to support it.
disconnectHandler ProtonConnection disconnectHandler(AmqpEventHandler!ProtonConnection disconnectHandler): Undocumented in source. Be warned that the author may not have intended to support it.
fireDisconnect void fireDisconnect(): 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.
fireRemoteLinkOpen void fireRemoteLinkOpen(Link link): Undocumented in source. Be warned that the author may not have intended to support it.
fireRemoteOpen void fireRemoteOpen(): Undocumented in source. Be warned that the author may not have intended to support it.
fireRemoteSessionOpen void fireRemoteSessionOpen(hunt.proton.engine.Session.Session session): Undocumented in source. Be warned that the author may not have intended to support it.
flush void flush(): 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.
getContainer string getContainer(): Undocumented in source. Be warned that the author may not have intended to support it.
getContext hunt.net.Connection.Connection getContext(): Undocumented in source. Be warned that the author may not have intended to support it.
getHostname string getHostname(): 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.
getRemoteCondition ErrorCondition getRemoteCondition(): Undocumented in source. Be warned that the author may not have intended to support it.
getRemoteContainer string getRemoteContainer(): Undocumented in source. Be warned that the author may not have intended to support it.
getRemoteDesiredCapabilities Symbol[] getRemoteDesiredCapabilities(): Undocumented in source. Be warned that the author may not have intended to support it.
getRemoteHostname string getRemoteHostname(): Undocumented in source. Be warned that the author may not have intended to support it.
getRemoteOfferedCapabilities Symbol[] getRemoteOfferedCapabilities(): Undocumented in source. Be warned that the author may not have intended to support it.
getRemoteProperties Map!(Symbol, Object) getRemoteProperties(): 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.
isAnonymousRelaySupported bool isAnonymousRelaySupported(): Undocumented in source. Be warned that the author may not have intended to support it.
isDisconnected bool isDisconnected(): Undocumented in source. Be warned that the author may not have intended to support it.
open ProtonConnection open(): ////////////////////////////////////////////////////////////////////////// //////////////////////////////////////////////////////////////////////////
openHandler ProtonConnection openHandler(Handler!ProtonConnection openHandler): Undocumented in source. Be warned that the author may not have intended to support it.
receiverOpenHandler ProtonConnection receiverOpenHandler(Handler!ProtonReceiver remoteReceiverOpenHandler): Undocumented in source. Be warned that the author may not have intended to support it.
senderOpenHandler ProtonConnection senderOpenHandler(Handler!ProtonSender remoteSenderOpenHandler): Undocumented in source. Be warned that the author may not have intended to support it.
sessionOpenHandler ProtonConnection sessionOpenHandler(AmqpEventHandler!ProtonSession remoteSessionOpenHandler): Undocumented in source. Be warned that the author may not have intended to support it.
setCondition ProtonConnectionImpl setCondition(ErrorCondition condition): Undocumented in source. Be warned that the author may not have intended to support it.
setContainer ProtonConnectionImpl setContainer(string container): Undocumented in source. Be warned that the author may not have intended to support it.
setDesiredCapabilities ProtonConnectionImpl setDesiredCapabilities(Symbol[] capabilities): Undocumented in source. Be warned that the author may not have intended to support it.
setHostname ProtonConnectionImpl setHostname(string hostname): Undocumented in source. Be warned that the author may not have intended to support it.
setOfferedCapabilities ProtonConnectionImpl setOfferedCapabilities(Symbol[] capabilities): Undocumented in source. Be warned that the author may not have intended to support it.
setProperties ProtonConnectionImpl setProperties(Map!(Symbol, Object) properties): ////////////////////////////////////////////////////////////////////////// //////////////////////////////////////////////////////////////////////////

Static functions

ANONYMOUS_RELAY Symbol ANONYMOUS_RELAY(): Undocumented in source. Be warned that the author may not have intended to support it.

Inherited Members

From ProtonConnection

open ProtonConnection open(): Opens the AMQP connection, i.e. allows the Open frame to be emitted. Typically used after any additional configuration is performed on the connection object.
close ProtonConnection close(): Closes the AMQP connection, i.e. allows the Close frame to be emitted.
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.
setContainer ProtonConnection setContainer(string container): Sets the container id value advertised to peers in the AMQP Open frame. Sometimes used as a 'client-id' by clients.
getContainer string getContainer(): Gets the container id value requested of/advertised to peers in the AMQP Open frame.
attachments Record attachments(): Retrieves the attachments record, upon which application items can be set/retrieved.
setProperties ProtonConnection setProperties(Map!(Symbol, Object) properties): Sets the connection properties map to be sent to the remote peer in our Open frame.
getRemoteProperties Map!(Symbol, Object) getRemoteProperties(): Returns the connection properties map if sent by the remote peer in its Open frame. May be null.
isAnonymousRelaySupported bool isAnonymousRelaySupported(): Allows querying (once the connection has remotely opened) whether the peer advertises support for the anonymous relay (sender with null address).
createSession ProtonSession createSession(): Creates a new session, which can be used to create new senders/receivers on.
disconnect void disconnect(): Disconnects the underlying transport connection. This can occur asynchronously and may not complete until some time after the method has returned.
isDisconnected bool isDisconnected(): Gets whether the underlying transport has indicated it is disconnected.
setHostname ProtonConnection setHostname(string hostname): Sets the hostname value requested of/advertised to peers in the AMQP Open frame.
getHostname string getHostname(): Gets the hostname value requested of/advertised to peers in the AMQP Open frame.
getRemoteContainer string getRemoteContainer(): Returns the container value requested by/advertised by remote peer in their AMQP Open frame.
setDesiredCapabilities ProtonConnection setDesiredCapabilities(Symbol[] capabilities): Sets the desired connection capabilities to be sent to the remote peer in our Open frame.
getRemoteDesiredCapabilities Symbol[] getRemoteDesiredCapabilities(): Returns the desired connection capabilities sent by the remote peer in its Open frame. May be null.
setOfferedCapabilities ProtonConnection setOfferedCapabilities(Symbol[] capabilities): Sets the offered connection capabilities to be sent to the remote peer in our Open frame.
getRemoteOfferedCapabilities Symbol[] getRemoteOfferedCapabilities(): Returns the offered connection capabilities sent by the remote peer in its Open frame. May be null.
getRemoteHostname string getRemoteHostname(): Returns the container value requested by/advertised by remote peer in their AMQP Open frame.
setCondition ProtonConnection 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 ProtonConnection openHandler(Handler!ProtonConnection remoteOpenHandler): Sets a handler for when an AMQP Open frame is received from the remote peer.
closeHandler ProtonConnection closeHandler(AsyncResultHandler!ProtonConnection closeHandler): Sets a handler for when an AMQP Close frame is received from the remote peer.
sessionOpenHandler ProtonConnection sessionOpenHandler(AmqpEventHandler!ProtonSession remoteSessionOpenHandler): Sets a handler for when an AMQP Begin frame is received from the remote peer.
senderOpenHandler ProtonConnection senderOpenHandler(Handler!ProtonSender remoteSenderOpenHandler): Sets a handler for when an AMQP Attach frame is received from the remote peer for a sending link.
receiverOpenHandler ProtonConnection receiverOpenHandler(Handler!ProtonReceiver remoteReceiverOpenHandler): Sets a handler for when an AMQP Attach frame is received from the remote peer for a receiving link.
disconnectHandler ProtonConnection disconnectHandler(AmqpEventHandler!ProtonConnection disconnectHandler): Sets a handler for when the underlying transport connection indicates it has disconnected.

ProtonConnectionImpl

Constructors

Members

Functions

Static functions

Inherited Members

From ProtonConnection

Meta

Source