public interface Connection extends Endpoint, ReactorChild
sessionHead(EnumSet, EnumSet)
, linkHead(EnumSet, EnumSet)
getWorkHead()
respectively.Modifier and Type | Interface and Description |
---|---|
static class |
Connection.Factory |
Modifier and Type | Method and Description |
---|---|
void |
collect(Collector collector) |
String |
getContainer() |
Object |
getContext() |
String |
getHostname() |
Reactor |
getReactor() |
String |
getRemoteContainer() |
Symbol[] |
getRemoteDesiredCapabilities() |
String |
getRemoteHostname() |
Symbol[] |
getRemoteOfferedCapabilities() |
Map<Symbol,Object> |
getRemoteProperties() |
Transport |
getTransport() |
Delivery |
getWorkHead()
Returns the head of the delivery work list.
|
Link |
linkHead(EnumSet<EndpointState> local,
EnumSet<EndpointState> remote)
Returns the head of the list of links in the specified states.
|
Session |
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 |
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 |
setOfferedCapabilities(Symbol[] capabilities) |
void |
setProperties(Map<Symbol,Object> properties) |
close, free, getCondition, getLocalState, getRemoteCondition, getRemoteState, open, setCondition
attachments
free
Session session()
Session sessionHead(EnumSet<EndpointState> local, EnumSet<EndpointState> remote)
Session.next(EnumSet, EnumSet)
Link linkHead(EnumSet<EndpointState> local, EnumSet<EndpointState> remote)
Link.next(EnumSet, EnumSet)
Delivery getWorkHead()
void setContainer(String container)
String getContainer()
void setHostname(String hostname)
String getHostname()
String getRemoteContainer()
String getRemoteHostname()
void setOfferedCapabilities(Symbol[] capabilities)
void setDesiredCapabilities(Symbol[] capabilities)
Symbol[] getRemoteOfferedCapabilities()
Symbol[] getRemoteDesiredCapabilities()
Object getContext()
getContext
in interface Endpoint
Endpoint.setContext(Object)
void setContext(Object context)
Endpoint
setContext
in interface Endpoint
void collect(Collector collector)
Transport getTransport()
Reactor getReactor()
Copyright © 2016 The Apache Software Foundation. All rights reserved.