public class ClusterClientHandler extends StoreClientHandler
Modifier and Type | Field and Description |
---|---|
protected long |
error |
protected int |
freq |
protected Serializer |
serializer |
embeddedSerializer, map, timeout
Constructor and Description |
---|
ClusterClientHandler() |
ClusterClientHandler(long timeout,
Serializer serializer) |
Modifier and Type | Method and Description |
---|---|
void |
exceptionCaught(org.jboss.netty.channel.ChannelHandlerContext ctx,
org.jboss.netty.channel.ExceptionEvent e) |
int |
getFreq() |
Serializer |
getSerializer() |
void |
messageReceived(org.jboss.netty.channel.ChannelHandlerContext ctx,
org.jboss.netty.channel.MessageEvent e)
based upon request type there are different way to handle request payload
Invoker type will just pass through, let client handle the
|
Response |
sendRequest(Request request,
org.jboss.netty.channel.Channel channel) |
void |
setFreq(int freq) |
channelConnected, channelInterestChanged, handleUpstream, invoke, sendMessage
protected Serializer serializer
protected int freq
protected long error
public ClusterClientHandler(long timeout, Serializer serializer)
public ClusterClientHandler()
public int getFreq()
public void setFreq(int freq)
public Serializer getSerializer()
public void exceptionCaught(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.ExceptionEvent e)
exceptionCaught
in class StoreClientHandler
public void messageReceived(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.MessageEvent e)
StoreClientHandler
messageReceived
in class StoreClientHandler
public Response sendRequest(Request request, org.jboss.netty.channel.Channel channel)
sendRequest
in interface Send
sendRequest
in class StoreClientHandler
request
- channel
- Copyright © 2016. All rights reserved.