public class InactiveRegionAwareRpcDispatcher extends CommandAwareRpcDispatcher
RpcDispatcher
and adds the possibility that the marshaller may throw InactiveRegionException
s.componentRegistry, interceptorChain, invocationContextContainer, log, trace
Constructor and Description |
---|
InactiveRegionAwareRpcDispatcher(org.jgroups.Channel channel,
org.jgroups.MessageListener l,
org.jgroups.MembershipListener l2,
Object serverObj,
InvocationContextContainer container,
InterceptorChain interceptorChain,
ComponentRegistry componentRegistry,
RPCManager manager)
Only provide the flavour of the
RpcDispatcher constructor that we care about. |
Modifier and Type | Method and Description |
---|---|
Object |
handle(org.jgroups.Message req)
Message contains MethodCall.
|
void |
setRequestMarshaller(org.jgroups.blocks.RpcDispatcher.Marshaller m) |
executeCommand, invokeRemoteCommands, isValid, setReplicationObserver, stopDispatcher, 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, 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
public InactiveRegionAwareRpcDispatcher(org.jgroups.Channel channel, org.jgroups.MessageListener l, org.jgroups.MembershipListener l2, Object serverObj, InvocationContextContainer container, InterceptorChain interceptorChain, ComponentRegistry componentRegistry, RPCManager manager)
RpcDispatcher
constructor that we care about.public void setRequestMarshaller(org.jgroups.blocks.RpcDispatcher.Marshaller m)
setRequestMarshaller
in class org.jgroups.blocks.RpcDispatcher
public Object handle(org.jgroups.Message req)
handle
in interface org.jgroups.blocks.RequestHandler
handle
in class CommandAwareRpcDispatcher
Copyright © 2012 JBoss, a division of Red Hat. All Rights Reserved.