public static class ProxyConnectionFactory.ProxyEndPoint
extends AttributesMap
| Constructor and Description |
|---|
ProxyEndPoint(EndPoint endp,
java.net.InetSocketAddress remote,
java.net.InetSocketAddress local) |
| Modifier and Type | Method and Description |
|---|---|
void |
close() |
int |
fill(java.nio.ByteBuffer buffer) |
void |
fillInterested(Callback callback) |
boolean |
flush(java.nio.ByteBuffer... buffer) |
Connection |
getConnection() |
long |
getCreatedTimeStamp() |
long |
getIdleTimeout() |
java.net.InetSocketAddress |
getLocalAddress() |
java.net.InetSocketAddress |
getRemoteAddress() |
java.lang.Object |
getTransport() |
boolean |
isFillInterested() |
boolean |
isInputShutdown() |
boolean |
isOpen() |
boolean |
isOptimizedForDirectBuffers() |
boolean |
isOutputShutdown() |
void |
onClose() |
void |
onOpen() |
void |
setConnection(Connection connection) |
void |
setIdleTimeout(long idleTimeout) |
void |
shutdownOutput() |
boolean |
tryFillInterested(Callback callback) |
void |
upgrade(Connection newConnection) |
void |
write(Callback callback,
java.nio.ByteBuffer... buffers) |
public ProxyEndPoint(EndPoint endp,
java.net.InetSocketAddress remote,
java.net.InetSocketAddress local)
public boolean isOptimizedForDirectBuffers()
public java.net.InetSocketAddress getLocalAddress()
public java.net.InetSocketAddress getRemoteAddress()
public boolean isOpen()
public long getCreatedTimeStamp()
public void shutdownOutput()
public boolean isOutputShutdown()
public boolean isInputShutdown()
public void close()
public int fill(java.nio.ByteBuffer buffer)
throws java.io.IOException
java.io.IOExceptionpublic boolean flush(java.nio.ByteBuffer... buffer)
throws java.io.IOException
java.io.IOExceptionpublic java.lang.Object getTransport()
public long getIdleTimeout()
public void setIdleTimeout(long idleTimeout)
public void fillInterested(Callback callback)
throws java.nio.channels.ReadPendingException
java.nio.channels.ReadPendingExceptionpublic boolean tryFillInterested(Callback callback)
public boolean isFillInterested()
public void write(Callback callback,
java.nio.ByteBuffer... buffers)
throws java.nio.channels.WritePendingException
java.nio.channels.WritePendingExceptionpublic Connection getConnection()
public void setConnection(Connection connection)
public void onOpen()
public void onClose()
public void upgrade(Connection newConnection)