public class CommandAwareRpcDispatcher
extends org.jgroups.blocks.RpcDispatcher
ReplicableCommand
s.Modifier and Type | Field and Description |
---|---|
protected ComponentRegistry |
componentRegistry |
protected InterceptorChain |
interceptorChain |
protected InvocationContextContainer |
invocationContextContainer |
protected org.apache.commons.logging.Log |
log |
protected boolean |
trace |
Constructor and Description |
---|
CommandAwareRpcDispatcher() |
CommandAwareRpcDispatcher(org.jgroups.Channel channel,
org.jgroups.MessageListener l,
org.jgroups.MembershipListener l2,
Object serverObj,
InvocationContextContainer container,
InterceptorChain interceptorChain,
ComponentRegistry componentRegistry,
RPCManager manager) |
Modifier and Type | Method and Description |
---|---|
protected Object |
executeCommand(ReplicableCommand cmd,
org.jgroups.Message req) |
Object |
handle(org.jgroups.Message req)
Message contains a Command.
|
org.jgroups.util.RspList |
invokeRemoteCommands(Vector<org.jgroups.Address> dests,
ReplicableCommand command,
int mode,
long timeout,
boolean anycasting,
boolean oob,
org.jgroups.blocks.RspFilter filter)
Similar to
#callRemoteMethods(java.util.Vector, org.jgroups.blocks.MethodCall, int, long, boolean, boolean, org.jgroups.blocks.RspFilter) except that this version
is aware of ReplicableCommand objects. |
protected boolean |
isValid(org.jgroups.Message req) |
ReplicationObserver |
setReplicationObserver(ReplicationObserver replicationObserver) |
void |
stopDispatcher() |
String |
toString() |
addChannelListener, callRemoteMethod, callRemoteMethod, callRemoteMethod, callRemoteMethod, callRemoteMethod, callRemoteMethod, callRemoteMethod, callRemoteMethods, callRemoteMethods, callRemoteMethods, callRemoteMethods, callRemoteMethods, callRemoteMethods, callRemoteMethods, callRemoteMethods, callRemoteMethodsWithFuture, callRemoteMethodsWithFuture, callRemoteMethodsWithFuture, callRemoteMethodWithFuture, callRemoteMethodWithFuture, callRemoteMethodWithFuture, channelClosed, channelConnected, channelDisconnected, channelReconnected, channelShunned, correlatorStarted, getMarshaller, getMethodLookup, getName, getRequestMarshaller, getResponseMarshaller, getServerObject, removeChannelListener, setMarshaller, setMethodLookup, setRequestMarshaller, setResponseMarshaller, setServerObject
cast, castMessage, castMessage, castMessage, castMessage, castMessageWithFuture, castMessageWithFuture, createRequestCorrelator, done, getChannel, getConcurrentProcessing, getDeadlockDetection, getMembers, getMessageListener, getProtocolAdapter, installUpHandler, send, sendMessage, sendMessage, sendMessageWithFuture, sendMessageWithFuture, setChannel, setConcurrentProcessing, setDeadlockDetection, setMembershipListener, setMessageListener, setRequestHandler, start, stop
protected InvocationContextContainer invocationContextContainer
protected InterceptorChain interceptorChain
protected ComponentRegistry componentRegistry
protected boolean trace
protected org.apache.commons.logging.Log log
public CommandAwareRpcDispatcher()
public CommandAwareRpcDispatcher(org.jgroups.Channel channel, org.jgroups.MessageListener l, org.jgroups.MembershipListener l2, Object serverObj, InvocationContextContainer container, InterceptorChain interceptorChain, ComponentRegistry componentRegistry, RPCManager manager)
public ReplicationObserver setReplicationObserver(ReplicationObserver replicationObserver)
public void stopDispatcher()
protected boolean isValid(org.jgroups.Message req)
public org.jgroups.util.RspList invokeRemoteCommands(Vector<org.jgroups.Address> dests, ReplicableCommand command, int mode, long timeout, boolean anycasting, boolean oob, org.jgroups.blocks.RspFilter filter) throws NotSerializableException, ExecutionException, InterruptedException
#callRemoteMethods(java.util.Vector, org.jgroups.blocks.MethodCall, int, long, boolean, boolean, org.jgroups.blocks.RspFilter)
except that this version
is aware of ReplicableCommand
objects.public Object handle(org.jgroups.Message req)
handle
in interface org.jgroups.blocks.RequestHandler
handle
in class org.jgroups.blocks.RpcDispatcher
protected Object executeCommand(ReplicableCommand cmd, org.jgroups.Message req) throws Throwable
Throwable
Copyright © 2012 JBoss, a division of Red Hat. All Rights Reserved.