public interface Connection extends Service
Modifier and Type | Method and Description |
---|---|
void |
dispatchAsync(Command command)
Sends a message to the client.
|
void |
dispatchSync(Command message)
Sends a message to the client.
|
String |
getConnectionId() |
Connector |
getConnector() |
int |
getDispatchQueueSize()
Returns the number of messages to be dispatched to this connection
|
String |
getRemoteAddress() |
ConnectionStatistics |
getStatistics()
Returns the statistics for this connection
|
boolean |
isActive() |
boolean |
isBlocked() |
boolean |
isConnected() |
boolean |
isFaultTolerantConnection() |
boolean |
isManageable() |
boolean |
isNetworkConnection()
return true if a network connection
|
boolean |
isSlow() |
Response |
service(Command command)
Services a client command and submits it to the broker.
|
void |
serviceException(Throwable error)
Handles an unexpected error associated with a connection.
|
void |
serviceExceptionAsync(IOException e) |
void |
updateClient(ConnectionControl control) |
Connector getConnector()
void dispatchSync(Command message)
message
- the message to send to the client.void dispatchAsync(Command command)
command
- Response service(Command command)
command
- void serviceException(Throwable error)
error
- boolean isSlow()
boolean isBlocked()
boolean isConnected()
boolean isActive()
int getDispatchQueueSize()
ConnectionStatistics getStatistics()
boolean isManageable()
String getRemoteAddress()
void serviceExceptionAsync(IOException e)
String getConnectionId()
boolean isNetworkConnection()
boolean isFaultTolerantConnection()
void updateClient(ConnectionControl control)
Copyright © 2005-2012 Apache Software Foundation. All Rights Reserved.