public class ConnectHandler.ClientToProxyConnection extends Object implements AsyncConnection
| Constructor and Description |
|---|
ConnectHandler.ClientToProxyConnection(ConcurrentMap<String,Object> context,
SocketChannel channel,
EndPoint endPoint,
long timestamp) |
| Modifier and Type | Method and Description |
|---|---|
void |
close() |
void |
closeClient() |
void |
closeServer() |
long |
getTimeStamp() |
Connection |
handle()
Handle the connection.
|
boolean |
isIdle() |
boolean |
isSuspended()
The semantic of this method is to return true to indicate interest in further reads,
or false otherwise, but it is misnamed and should be really called
isReadInterested(). |
void |
onClose()
Called after the connection is closed
|
void |
onIdleExpired(long idleForMs)
Called when the connection idle timeout expires
|
void |
onInputShutdown() |
void |
setConnection(ConnectHandler.ProxyToServerConnection connection) |
void |
shutdownOutput() |
String |
toString() |
public ConnectHandler.ClientToProxyConnection(ConcurrentMap<String,Object> context, SocketChannel channel, EndPoint endPoint, long timestamp)
public Connection handle() throws IOException
Connectionhandle in interface ConnectionIOException - if the handling of I/O operations failpublic void onInputShutdown()
throws IOException
onInputShutdown in interface AsyncConnectionIOExceptionpublic long getTimeStamp()
getTimeStamp in interface Connectionpublic boolean isIdle()
isIdle in interface ConnectionConnection.onIdleExpired(long)public boolean isSuspended()
ConnectionThe semantic of this method is to return true to indicate interest in further reads,
or false otherwise, but it is misnamed and should be really called isReadInterested().
isSuspended in interface Connectionpublic void onClose()
ConnectiononClose in interface Connectionpublic void setConnection(ConnectHandler.ProxyToServerConnection connection)
public void closeClient()
throws IOException
IOExceptionpublic void closeServer()
throws IOException
IOExceptionpublic void close()
public void shutdownOutput()
throws IOException
IOExceptionpublic void onIdleExpired(long idleForMs)
ConnectiononIdleExpired in interface ConnectionidleForMs - how long the connection has been idleConnection.isIdle()Copyright © 1995-2015 Mort Bay Consulting. All Rights Reserved.