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.
|
int |
getActiveTransactionCount()
Returns the number of active transactions established on this Connection.
|
String |
getConnectionId() |
Connector |
getConnector() |
int |
getDispatchQueueSize()
Returns the number of messages to be dispatched to this connection
|
Long |
getOldestActiveTransactionDuration()
Returns the number of active transactions established on 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)
int getActiveTransactionCount()
Long getOldestActiveTransactionDuration()
Copyright © 2005–2022 FuseSource, Corp.. All rights reserved.