public abstract class ConnectionBase
extends java.lang.Object
| Modifier and Type | Field and Description |
|---|---|
protected org.jboss.netty.channel.Channel |
channel |
protected Handler<java.lang.Void> |
closedHandler |
protected Context |
context |
protected Handler<java.lang.Exception> |
exceptionHandler |
protected VertxInternal |
vertx |
| Modifier | Constructor and Description |
|---|---|
protected |
ConnectionBase(VertxInternal vertx,
org.jboss.netty.channel.Channel channel,
Context context) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
addFuture(Handler<java.lang.Void> doneHandler,
org.jboss.netty.channel.ChannelFuture future) |
void |
close()
Close the connection
|
void |
closedHandler(Handler<java.lang.Void> handler)
Set a closed handler on the connection
|
void |
exceptionHandler(Handler<java.lang.Exception> handler)
Set an exception handler on the connection
|
protected Context |
getContext() |
protected void |
handleClosed() |
protected void |
handleException(java.lang.Exception e) |
protected void |
handleHandlerException(java.lang.Throwable t) |
protected boolean |
isSSL() |
void |
pause()
Pause the connection, see
ReadStream.pause() |
void |
resume()
Resume the connection, see
ReadStream.resume() |
protected org.jboss.netty.channel.ChannelFuture |
sendFile(java.io.File file) |
protected void |
setContext() |
void |
setWriteQueueMaxSize(int size)
Set the max size for the write queue, see
WriteStream.setWriteQueueMaxSize(int) |
boolean |
writeQueueFull()
Is the write queue full?, see
WriteStream.writeQueueFull() |
protected final VertxInternal vertx
protected final org.jboss.netty.channel.Channel channel
protected final Context context
protected Handler<java.lang.Exception> exceptionHandler
protected Handler<java.lang.Void> closedHandler
protected ConnectionBase(VertxInternal vertx, org.jboss.netty.channel.Channel channel, Context context)
public void pause()
ReadStream.pause()public void resume()
ReadStream.resume()public void setWriteQueueMaxSize(int size)
WriteStream.setWriteQueueMaxSize(int)public boolean writeQueueFull()
WriteStream.writeQueueFull()public void close()
public void exceptionHandler(Handler<java.lang.Exception> handler)
public void closedHandler(Handler<java.lang.Void> handler)
protected Context getContext()
protected void handleException(java.lang.Exception e)
protected void handleClosed()
protected void addFuture(Handler<java.lang.Void> doneHandler, org.jboss.netty.channel.ChannelFuture future)
protected void setContext()
protected void handleHandlerException(java.lang.Throwable t)
protected boolean isSSL()
protected org.jboss.netty.channel.ChannelFuture sendFile(java.io.File file)