public class RequestHandlerTCP<K extends FutureResponse>
extends org.jboss.netty.channel.SimpleChannelHandler
RequestHandlerUDP
, which is used for
UDP.Constructor and Description |
---|
RequestHandlerTCP(K futureResponse,
PeerBean peerBean,
ConnectionBean connectionBean,
Message message) |
Modifier and Type | Method and Description |
---|---|
void |
channelClosed(org.jboss.netty.channel.ChannelHandlerContext ctx,
org.jboss.netty.channel.ChannelStateEvent e) |
void |
exceptionCaught(org.jboss.netty.channel.ChannelHandlerContext ctx,
org.jboss.netty.channel.ExceptionEvent e) |
K |
fireAndForgetTCP(ChannelCreator channelCreator) |
K |
fireAndForgetTCP(ChannelCreator channelCreator,
int idleTCPMillis) |
K |
getFutureResponse() |
protected PeerMap |
getPeerMap() |
void |
messageReceived(org.jboss.netty.channel.ChannelHandlerContext ctx,
org.jboss.netty.channel.MessageEvent e) |
K |
sendTCP(ChannelCreator channelCreator) |
K |
sendTCP(ChannelCreator channelCreator,
int idleTCPMillis) |
void |
setKeepAlive(boolean isKeepAlive) |
bindRequested, channelBound, channelConnected, channelDisconnected, channelInterestChanged, channelOpen, channelUnbound, childChannelClosed, childChannelOpen, closeRequested, connectRequested, disconnectRequested, handleDownstream, handleUpstream, setInterestOpsRequested, unbindRequested, writeComplete, writeRequested
public RequestHandlerTCP(K futureResponse, PeerBean peerBean, ConnectionBean connectionBean, Message message)
objectHolder
- the bean representing the node this handler belongs topublic K getFutureResponse()
public K sendTCP(ChannelCreator channelCreator)
public K sendTCP(ChannelCreator channelCreator, int idleTCPMillis)
public K fireAndForgetTCP(ChannelCreator channelCreator)
public K fireAndForgetTCP(ChannelCreator channelCreator, int idleTCPMillis)
protected PeerMap getPeerMap()
public void setKeepAlive(boolean isKeepAlive)
public void exceptionCaught(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.ExceptionEvent e)
exceptionCaught
in class org.jboss.netty.channel.SimpleChannelHandler
public void messageReceived(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.MessageEvent e) throws Exception
messageReceived
in class org.jboss.netty.channel.SimpleChannelHandler
Exception
Copyright © 2013. All Rights Reserved.