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)