public class UnisonServerHandler extends ReplicaServerHandler
Modifier and Type | Field and Description |
---|---|
protected UnisonCallBack |
callback |
static String |
CMP |
protected Persistence |
localStore |
freq, maxQueue, maxThreads, serverState, threadPools
Constructor and Description |
---|
UnisonServerHandler(UnisonCallBack callback) |
UnisonServerHandler(UnisonCallBack callback,
Persistence localStore) |
Modifier and Type | Method and Description |
---|---|
Persistence |
getLocalStore() |
protected void |
init() |
protected boolean |
isNeedRecovery() |
void |
messageReceived(org.jboss.netty.channel.ChannelHandlerContext ctx,
org.jboss.netty.channel.MessageEvent e) |
protected void |
recoveryTrx() |
exceptionCaught, getFreq, handleUpstream, processParaList, processRequest, setError, setFreq, shutdown
protected UnisonCallBack callback
protected Persistence localStore
public static final String CMP
public UnisonServerHandler(UnisonCallBack callback)
public UnisonServerHandler(UnisonCallBack callback, Persistence localStore)
protected void init()
public Persistence getLocalStore()
protected void recoveryTrx()
protected boolean isNeedRecovery()
public void messageReceived(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.MessageEvent e)
messageReceived
in class ReplicaServerHandler
Copyright © 2016. All rights reserved.