Connection

Maintains lists of sessions, links and deliveries in a state that is interesting to the application.

These are exposed by returning the head of those lists via {@link #sessionHead(EnumSet, EnumSet)}, {@link #linkHead(EnumSet, EnumSet)} {@link #getWorkHead()} respectively.

Members

Classes

Factory class Factory: Undocumented in source.

Functions

collect void collect(Collector collector): Undocumented in source.
getContainer string getContainer(): Undocumented in source.
getContext Object getContext(): Undocumented in source.
getHostname string getHostname(): Undocumented in source.
getReactor Reactor getReactor(): Undocumented in source.
getRemoteContainer string getRemoteContainer(): Undocumented in source.
getRemoteDesiredCapabilities Symbol[] getRemoteDesiredCapabilities(): Undocumented in source.
getRemoteHostname string getRemoteHostname(): Undocumented in source.
getRemoteOfferedCapabilities Symbol[] getRemoteOfferedCapabilities(): Undocumented in source.
getRemoteProperties Map!(Symbol, Object) getRemoteProperties(): Undocumented in source.
getTransport Transport getTransport(): Undocumented in source.
getWorkHead Delivery getWorkHead(): Returns the head of the delivery work list. The delivery work list consists of unsettled deliveries whose state has been changed by the other container and not yet locally processed.
linkHead Link linkHead(Set!EndpointState local, Set!EndpointState remote): Returns the head of the list of links in the specified states.
session Session session(): Returns a newly created session
sessionHead Session sessionHead(Set!EndpointState local, Set!EndpointState remote): Returns the head of the list of sessions in the specified states.
setContainer void setContainer(string container): Undocumented in source.
setContext void setContext(Object context): Undocumented in source.
setDesiredCapabilities void setDesiredCapabilities(Symbol[] capabilities): Undocumented in source.
setHostname void setHostname(string hostname): Set the name of the host (either fully qualified or relative) to which this connection is connecting to. This information may be used by the remote peer to determine the correct back-end service to connect the client to. This value will be sent in the Open performative.
setOfferedCapabilities void setOfferedCapabilities(Symbol[] capabilities): Undocumented in source.
setProperties void setProperties(Map!(Symbol, Object) properties): Undocumented in source.

Inherited Members

From Endpoint

getLocalState EndpointState getLocalState(): @return the local endpoint state
getRemoteState EndpointState getRemoteState(): @return the remote endpoint state (as last communicated)
getCondition ErrorCondition getCondition(): @return the local endpoint error, or null if there is none
setCondition void setCondition(ErrorCondition condition): Set the local error condition @param condition
getRemoteCondition ErrorCondition getRemoteCondition(): @return the remote endpoint error, or null if there is none
free void free(): free the endpoint and any associated resources
open void open(): transition local state to ACTIVE
close void close(): transition local state to CLOSED
setContext void setContext(Object o): Sets an arbitrary an application owned object on the end-point. This object is not used by Proton.
getContext Object getContext(): @see #setContext(Object)

From ReactorChild

free void free(): Frees any resources associated with this child.
opCmp int opCmp(ReactorChild o): Undocumented in source.