Class ConnectionImpl
java.lang.Object
org.apache.qpid.proton.engine.impl.EndpointImpl
org.apache.qpid.proton.engine.impl.ConnectionImpl
- All Implemented Interfaces:
Connection
,Endpoint
,Extendable
,ProtonJConnection
,ProtonJEndpoint
,ReactorChild
-
Nested Class Summary
Nested classes/interfaces inherited from interface org.apache.qpid.proton.engine.Connection
Connection.Factory
-
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected org.apache.qpid.proton.engine.impl.LinkNode<LinkImpl>
addLinkEndpoint
(LinkImpl endpoint) protected org.apache.qpid.proton.engine.impl.LinkNode<SessionImpl>
addSessionEndpoint
(SessionImpl endpoint) void
protected ConnectionImpl
int
Symbol[]
Symbol[]
Returns the head of the delivery work list.linkHead
(EnumSet<EndpointState> local, EnumSet<EndpointState> remote) Returns the head of the list of links in the specified states.void
removeTransportWork
(DeliveryImpl delivery) session()
Returns a newly created session TODO does the Connection's channel-max property limit how many sessions can be created, or opened, or neither?sessionHead
(EnumSet<EndpointState> local, EnumSet<EndpointState> remote) Returns the head of the list of sessions in the specified states.void
setContainer
(String container) void
setContext
(Object context) Sets an arbitrary an application owned object on the end-point.void
setDesiredCapabilities
(Symbol[] capabilities) void
setHostname
(String hostname) Set the name of the host (either fully qualified or relative) to which this connection is connecting to.void
setLocalContainerId
(String localContainerId) void
setOfferedCapabilities
(Symbol[] capabilities) void
setProperties
(Map<Symbol, Object> properties) void
setReactor
(Reactor reactor) Methods inherited from class org.apache.qpid.proton.engine.impl.EndpointImpl
attachments, close, free, getCondition, getLocalState, getRemoteCondition, getRemoteState, open, setCondition
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface org.apache.qpid.proton.engine.Endpoint
close, free, getCondition, getLocalState, getRemoteCondition, getRemoteState, open, setCondition
Methods inherited from interface org.apache.qpid.proton.engine.Extendable
attachments
Methods inherited from interface org.apache.qpid.proton.reactor.ReactorChild
free
-
Field Details
-
MAX_CHANNELS
public static final int MAX_CHANNELS- See Also:
-
-
Constructor Details
-
ConnectionImpl
public ConnectionImpl()Application code should useConnection.Factory.create()
instead.
-
-
Method Details
-
session
Description copied from interface:Connection
Returns a newly created session TODO does the Connection's channel-max property limit how many sessions can be created, or opened, or neither?- Specified by:
session
in interfaceConnection
- Specified by:
session
in interfaceProtonJConnection
-
addSessionEndpoint
protected org.apache.qpid.proton.engine.impl.LinkNode<SessionImpl> addSessionEndpoint(SessionImpl endpoint) -
addLinkEndpoint
-
sessionHead
Description copied from interface:Connection
Returns the head of the list of sessions in the specified states. Typically used to discover sessions whose remote state has acquired particular values, e.g. sessions that have been remotely opened or closed. TODO what ordering guarantees on the returned "linked list" are provided?- Specified by:
sessionHead
in interfaceConnection
- See Also:
-
linkHead
Description copied from interface:Connection
Returns the head of the list of links in the specified states. Typically used to discover links whose remote state has acquired particular values, e.g. links that have been remotely opened or closed.- Specified by:
linkHead
in interfaceConnection
- See Also:
-
getConnectionImpl
- Specified by:
getConnectionImpl
in classEndpointImpl
-
getMaxChannels
public int getMaxChannels()- Specified by:
getMaxChannels
in interfaceProtonJConnection
-
getLocalContainerId
-
setLocalContainerId
- Specified by:
setLocalContainerId
in interfaceProtonJConnection
-
getWorkHead
Description copied from interface:Connection
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.- Specified by:
getWorkHead
in interfaceConnection
- See Also:
-
setContainer
- Specified by:
setContainer
in interfaceConnection
-
getContainer
- Specified by:
getContainer
in interfaceConnection
-
setHostname
Description copied from interface:Connection
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. Note that it is illegal to set the hostname to a numeric IP address or include a port number.- Specified by:
setHostname
in interfaceConnection
- Parameters:
hostname
- the RFC1035 compliant host name.
-
getRemoteContainer
- Specified by:
getRemoteContainer
in interfaceConnection
-
getRemoteHostname
- Specified by:
getRemoteHostname
in interfaceConnection
-
setOfferedCapabilities
- Specified by:
setOfferedCapabilities
in interfaceConnection
-
setDesiredCapabilities
- Specified by:
setDesiredCapabilities
in interfaceConnection
-
getRemoteOfferedCapabilities
- Specified by:
getRemoteOfferedCapabilities
in interfaceConnection
-
getRemoteDesiredCapabilities
- Specified by:
getRemoteDesiredCapabilities
in interfaceConnection
-
setProperties
- Specified by:
setProperties
in interfaceConnection
-
getRemoteProperties
- Specified by:
getRemoteProperties
in interfaceConnection
-
getHostname
- Specified by:
getHostname
in interfaceConnection
-
getWorkSequence
-
getTransport
- Specified by:
getTransport
in interfaceConnection
-
removeTransportWork
-
getContext
- Specified by:
getContext
in interfaceConnection
- Specified by:
getContext
in interfaceEndpoint
- Overrides:
getContext
in classEndpointImpl
- See Also:
-
setContext
Description copied from interface:Endpoint
Sets an arbitrary an application owned object on the end-point. This object is not used by Proton.- Specified by:
setContext
in interfaceConnection
- Specified by:
setContext
in interfaceEndpoint
- Overrides:
setContext
in classEndpointImpl
-
collect
- Specified by:
collect
in interfaceConnection
-
getReactor
- Specified by:
getReactor
in interfaceConnection
-
setReactor
-