org.apache.qpid.proton.engine.impl

Class ConnectionImpl

java.lang.Object

org.apache.qpid.proton.engine.impl.EndpointImpl

org.apache.qpid.proton.engine.impl.ConnectionImpl

All Implemented Interfaces:

Connection, Endpoint, ProtonJConnection, ProtonJEndpoint

public class ConnectionImpl
extends EndpointImpl
implements ProtonJConnection

Field Summary

Fields

Modifier and Type	Field and Description
static int	MAX_CHANNELS

Constructor Summary

Constructors

Constructor and Description
ConnectionImpl() Deprecated. This constructor's visibility will be reduced to the default scope in a future release. Client code outside this module should use a EngineFactory instead

Method Summary

Methods

Modifier and Type	Method and Description
protected org.apache.qpid.proton.engine.impl.LinkNode<LinkImpl>	addLinkEndpoint(LinkImpl endpoint)
protected org.apache.qpid.proton.engine.impl.LinkNode<SessionImpl>	addSessionEndpoint(SessionImpl endpoint)
void	free()
protected ConnectionImpl	getConnectionImpl()
java.lang.Object	getContext()
java.lang.String	getHostname()
java.lang.String	getLocalContainerId()
int	getMaxChannels()
java.lang.String	getRemoteContainer()
Symbol[]	getRemoteDesiredCapabilities()
java.lang.String	getRemoteHostname()
Symbol[]	getRemoteOfferedCapabilities()
java.util.Map<Symbol,java.lang.Object>	getRemoteProperties()
DeliveryImpl	getWorkHead()
java.util.Iterator<DeliveryImpl>	getWorkSequence()
void	handleOpen(Open open)
boolean	isBound()
Link	linkHead(java.util.EnumSet<EndpointState> local, java.util.EnumSet<EndpointState> remote)
void	removeTransportWork(DeliveryImpl delivery)
SessionImpl	session()
Session	sessionHead(java.util.EnumSet<EndpointState> local, java.util.EnumSet<EndpointState> remote)
void	setBound(boolean bound)
void	setContainer(java.lang.String container)
void	setContext(java.lang.Object context)
void	setDesiredCapabilities(Symbol[] capabilities)
void	setHostname(java.lang.String hostname)
void	setLocalContainerId(java.lang.String localContainerId)
void	setOfferedCapabilities(Symbol[] capabilities)
void	setProperties(java.util.Map<Symbol,java.lang.Object> properties)

Methods inherited from class org.apache.qpid.proton.engine.impl.EndpointImpl

close, getCondition, getLocalState, getRemoteCondition, getRemoteState, open, setCondition, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.qpid.proton.engine.Endpoint

close, getCondition, getLocalState, getRemoteCondition, getRemoteState, open, setCondition

Field Detail

MAX_CHANNELS

public static final int MAX_CHANNELS

See Also:

Constant Field Values

Constructor Detail

ConnectionImpl

@Deprecated
public ConnectionImpl()

Deprecated. This constructor's visibility will be reduced to the default scope in a future release. Client code outside this module should use a EngineFactory instead

Method Detail

session

public SessionImpl session()

Specified by:

session in interface Connection

Specified by:

session in interface ProtonJConnection

addSessionEndpoint

protected org.apache.qpid.proton.engine.impl.LinkNode<SessionImpl> addSessionEndpoint(SessionImpl endpoint)

addLinkEndpoint

protected org.apache.qpid.proton.engine.impl.LinkNode<LinkImpl> addLinkEndpoint(LinkImpl endpoint)

sessionHead

public Session sessionHead(java.util.EnumSet<EndpointState> local,
                  java.util.EnumSet<EndpointState> remote)

Specified by:

sessionHead in interface Connection

linkHead

public Link linkHead(java.util.EnumSet<EndpointState> local,
            java.util.EnumSet<EndpointState> remote)

Specified by:

linkHead in interface Connection

getConnectionImpl

protected ConnectionImpl getConnectionImpl()

Specified by:

getConnectionImpl in class EndpointImpl

free

public void free()

Specified by:

free in interface Endpoint

Overrides:

free in class EndpointImpl

handleOpen

public void handleOpen(Open open)

getMaxChannels

public int getMaxChannels()

Specified by:

getMaxChannels in interface ProtonJConnection

getLocalContainerId

public java.lang.String getLocalContainerId()

setLocalContainerId

public void setLocalContainerId(java.lang.String localContainerId)

Specified by:

setLocalContainerId in interface ProtonJConnection

getWorkHead

public DeliveryImpl getWorkHead()

Specified by:

getWorkHead in interface Connection

setContainer

public void setContainer(java.lang.String container)

Specified by:

setContainer in interface Connection

setHostname

public void setHostname(java.lang.String hostname)

Specified by:

setHostname in interface Connection

getRemoteContainer

public java.lang.String getRemoteContainer()

Specified by:

getRemoteContainer in interface Connection

getRemoteHostname

public java.lang.String getRemoteHostname()

Specified by:

getRemoteHostname in interface Connection

setOfferedCapabilities

public void setOfferedCapabilities(Symbol[] capabilities)

Specified by:

setOfferedCapabilities in interface Connection

setDesiredCapabilities

public void setDesiredCapabilities(Symbol[] capabilities)

Specified by:

setDesiredCapabilities in interface Connection

getRemoteOfferedCapabilities

public Symbol[] getRemoteOfferedCapabilities()

Specified by:

getRemoteOfferedCapabilities in interface Connection

getRemoteDesiredCapabilities

public Symbol[] getRemoteDesiredCapabilities()

Specified by:

getRemoteDesiredCapabilities in interface Connection

setProperties

public void setProperties(java.util.Map<Symbol,java.lang.Object> properties)

Specified by:

setProperties in interface Connection

getRemoteProperties

public java.util.Map<Symbol,java.lang.Object> getRemoteProperties()

Specified by:

getRemoteProperties in interface Connection

getHostname

public java.lang.String getHostname()

getWorkSequence

public java.util.Iterator<DeliveryImpl> getWorkSequence()

setBound

public void setBound(boolean bound)

isBound

public boolean isBound()

removeTransportWork

public void removeTransportWork(DeliveryImpl delivery)

getContext

public java.lang.Object getContext()

Specified by:

getContext in interface Connection

Specified by:

getContext in interface Endpoint

Overrides:

getContext in class EndpointImpl

setContext

public void setContext(java.lang.Object context)

Specified by:

setContext in interface Connection

Specified by:

setContext in interface Endpoint

Overrides:

setContext in class EndpointImpl