public class ConnectionImpl extends EndpointImpl implements ProtonJConnection
Modifier and Type | Field and Description |
---|---|
static int |
MAX_CHANNELS |
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 |
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()
free the endpoint and any associated resources
|
protected ConnectionImpl |
getConnectionImpl() |
Object |
getContext() |
String |
getHostname() |
String |
getLocalContainerId() |
int |
getMaxChannels() |
String |
getRemoteContainer() |
Symbol[] |
getRemoteDesiredCapabilities() |
String |
getRemoteHostname() |
Symbol[] |
getRemoteOfferedCapabilities() |
Map<Symbol,Object> |
getRemoteProperties() |
DeliveryImpl |
getWorkHead()
Returns the head of the delivery work list.
|
Iterator<DeliveryImpl> |
getWorkSequence() |
void |
handleOpen(Open open) |
boolean |
isBound() |
Link |
linkHead(EnumSet<EndpointState> local,
EnumSet<EndpointState> remote)
Returns the head of the list of links in the specified states.
|
void |
removeTransportWork(DeliveryImpl delivery) |
SessionImpl |
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?
|
Session |
sessionHead(EnumSet<EndpointState> local,
EnumSet<EndpointState> remote)
Returns the head of the list of sessions in the specified states.
|
void |
setBound(boolean bound) |
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) |
void |
setLocalContainerId(String localContainerId) |
void |
setOfferedCapabilities(Symbol[] capabilities) |
void |
setProperties(Map<Symbol,Object> properties) |
close, getCondition, getLocalState, getRemoteCondition, getRemoteState, open, setCondition, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
close, getCondition, getLocalState, getRemoteCondition, getRemoteState, open, setCondition
public static final int MAX_CHANNELS
@Deprecated public ConnectionImpl()
EngineFactory
insteadpublic SessionImpl session()
Connection
session
in interface Connection
session
in interface ProtonJConnection
protected org.apache.qpid.proton.engine.impl.LinkNode<SessionImpl> addSessionEndpoint(SessionImpl endpoint)
protected org.apache.qpid.proton.engine.impl.LinkNode<LinkImpl> addLinkEndpoint(LinkImpl endpoint)
public Session sessionHead(EnumSet<EndpointState> local, EnumSet<EndpointState> remote)
Connection
sessionHead
in interface Connection
Session.next(EnumSet, EnumSet)
public Link linkHead(EnumSet<EndpointState> local, EnumSet<EndpointState> remote)
Connection
linkHead
in interface Connection
Link.next(EnumSet, EnumSet)
protected ConnectionImpl getConnectionImpl()
getConnectionImpl
in class EndpointImpl
public void free()
Endpoint
free
in interface Endpoint
free
in class EndpointImpl
public void handleOpen(Open open)
public int getMaxChannels()
getMaxChannels
in interface ProtonJConnection
public String getLocalContainerId()
public void setLocalContainerId(String localContainerId)
setLocalContainerId
in interface ProtonJConnection
public DeliveryImpl getWorkHead()
Connection
getWorkHead
in interface Connection
Receiver.recv(byte[], int, int)
,
Delivery.settle()
,
Delivery.getWorkNext()
public void setContainer(String container)
setContainer
in interface Connection
public void setHostname(String hostname)
setHostname
in interface Connection
public String getRemoteContainer()
getRemoteContainer
in interface Connection
public String getRemoteHostname()
getRemoteHostname
in interface Connection
public void setOfferedCapabilities(Symbol[] capabilities)
setOfferedCapabilities
in interface Connection
public void setDesiredCapabilities(Symbol[] capabilities)
setDesiredCapabilities
in interface Connection
public Symbol[] getRemoteOfferedCapabilities()
getRemoteOfferedCapabilities
in interface Connection
public Symbol[] getRemoteDesiredCapabilities()
getRemoteDesiredCapabilities
in interface Connection
public void setProperties(Map<Symbol,Object> properties)
setProperties
in interface Connection
public Map<Symbol,Object> getRemoteProperties()
getRemoteProperties
in interface Connection
public String getHostname()
public Iterator<DeliveryImpl> getWorkSequence()
public void setBound(boolean bound)
public boolean isBound()
public void removeTransportWork(DeliveryImpl delivery)
public Object getContext()
getContext
in interface Connection
getContext
in interface Endpoint
getContext
in class EndpointImpl
Endpoint.setContext(Object)
public void setContext(Object context)
Endpoint
setContext
in interface Connection
setContext
in interface Endpoint
setContext
in class EndpointImpl
Copyright © 2014 The Apache Software Foundation. All rights reserved.