C
- application supplied contextpublic interface Connector<C>
Connection
and the I/O
layer.
The top half of the engine can be access via getConnection()
.
The bottom half of the engine is used by process()
.
Stores application specific context using setContext(Object)
.
Implementations are not necessarily thread-safe.Modifier and Type | Method and Description |
---|---|
void |
close()
Close the socket used by the connector.
|
void |
destroy()
Destructor for the given connector.
|
Connection |
getConnection()
Access the AMQP Connection associated with the connector.
|
C |
getContext()
Access the application context that is associated with the connector.
|
Transport |
getTransport()
Access the Transport associated with the connector.
|
boolean |
isClosed()
Determine if the connector is closed.
|
Listener |
listener()
Access the listener which opened this connector.
|
boolean |
process()
Handle any inbound data, outbound data, or timing events pending on
the connector.
|
Sasl |
sasl()
Access the Authentication and Security context of the connector.
|
void |
setConnection(Connection connection)
Assign the AMQP Connection associated with the connector.
|
void |
setContext(C context)
Assign a new application context to the connector.
|
boolean process() throws IOException
IOException
Listener listener()
Sasl sasl()
Transport getTransport()
Connection getConnection()
void setConnection(Connection connection)
connection
- the connection to associate with the connector.C getContext()
createConnector(String, int, Object)
and
createConnector(java.nio.channels.SelectableChannel, Object)
.void setContext(C context)
context
- new application context to associate with the connectorvoid close()
boolean isClosed()
void destroy()
Copyright © 2016 The Apache Software Foundation. All rights reserved.