public class HChannelHandler
extends org.jboss.netty.channel.SimpleChannelHandler
Constructor and Description |
---|
HChannelHandler(ClientConfiguration cfg,
AbstractHChannelManager channelManager,
Map<PubSubProtocol.OperationType,AbstractResponseHandler> handlers) |
Modifier and Type | Method and Description |
---|---|
void |
addTxn(long txnId,
PubSubData pubSubData) |
void |
channelConnected(org.jboss.netty.channel.ChannelHandlerContext ctx,
org.jboss.netty.channel.ChannelStateEvent e) |
void |
channelDisconnected(org.jboss.netty.channel.ChannelHandlerContext ctx,
org.jboss.netty.channel.ChannelStateEvent e) |
void |
checkTimeoutRequests() |
void |
closeExplicitly() |
void |
exceptionCaught(org.jboss.netty.channel.ChannelHandlerContext ctx,
org.jboss.netty.channel.ExceptionEvent e) |
SubscribeResponseHandler |
getSubscribeResponseHandler() |
void |
messageReceived(org.jboss.netty.channel.ChannelHandlerContext ctx,
org.jboss.netty.channel.MessageEvent e) |
void |
removeTxn(long txnId) |
bindRequested, channelBound, channelClosed, channelInterestChanged, channelOpen, channelUnbound, childChannelClosed, childChannelOpen, closeRequested, connectRequested, disconnectRequested, handleDownstream, handleUpstream, setInterestOpsRequested, unbindRequested, writeComplete, writeRequested
public HChannelHandler(ClientConfiguration cfg, AbstractHChannelManager channelManager, Map<PubSubProtocol.OperationType,AbstractResponseHandler> handlers)
public SubscribeResponseHandler getSubscribeResponseHandler()
public void removeTxn(long txnId)
public void addTxn(long txnId, PubSubData pubSubData)
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
public void checkTimeoutRequests()
public void channelDisconnected(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.ChannelStateEvent e) throws Exception
channelDisconnected
in class org.jboss.netty.channel.SimpleChannelHandler
Exception
public void channelConnected(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.ChannelStateEvent e) throws Exception
channelConnected
in class org.jboss.netty.channel.SimpleChannelHandler
Exception
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 closeExplicitly()
Copyright © 2011–2016 The Apache Software Foundation. All rights reserved.