public class CommandAwareRpcDispatcher
extends org.jgroups.blocks.RpcDispatcher
ReplicableCommand
s.Constructor and Description |
---|
CommandAwareRpcDispatcher(org.jgroups.Channel channel,
JGroupsTransport transport,
ExecutorService asyncExecutor,
InboundInvocationHandler inboundInvocationHandler) |
Modifier and Type | Method and Description |
---|---|
org.jgroups.util.RspList<Object> |
broadcastRemoteCommands(ReplicableCommand command,
org.jgroups.blocks.ResponseMode mode,
long timeout,
boolean anycasting,
boolean oob,
org.jgroups.blocks.RspFilter filter,
boolean supportReplay,
boolean asyncMarshalling) |
Object |
handle(org.jgroups.Message req)
Message contains a Command.
|
Response |
invokeRemoteCommand(org.jgroups.Address recipient,
ReplicableCommand command,
org.jgroups.blocks.ResponseMode mode,
long timeout,
boolean oob,
boolean supportReplay,
boolean asyncMarshalling) |
org.jgroups.util.RspList<Object> |
invokeRemoteCommands(List<org.jgroups.Address> recipients,
ReplicableCommand command,
org.jgroups.blocks.ResponseMode mode,
long timeout,
boolean anycasting,
boolean oob,
org.jgroups.blocks.RspFilter filter,
boolean supportReplay,
boolean asyncMarshalling) |
String |
toString() |
callRemoteMethod, callRemoteMethod, callRemoteMethods, callRemoteMethods, callRemoteMethodsWithFuture, callRemoteMethodWithFuture, correlatorStarted, getMarshaller, getMethodLookup, getName, getRequestMarshaller, getResponseMarshaller, getServerObject, setMarshaller, setMethodLookup, setRequestMarshaller, setResponseMarshaller, setServerObject
addChannelListener, cast, castMessage, castMessageWithFuture, channelClosed, channelConnected, channelDisconnected, createRequestCorrelator, done, getChannel, getMessageListener, getProtocolAdapter, installUpHandler, removeChannelListener, sendMessage, sendMessageWithFuture, setChannel, setMembers, setMembershipListener, setMessageListener, setRequestHandler, start, stop
public CommandAwareRpcDispatcher(org.jgroups.Channel channel, JGroupsTransport transport, ExecutorService asyncExecutor, InboundInvocationHandler inboundInvocationHandler)
public org.jgroups.util.RspList<Object> invokeRemoteCommands(List<org.jgroups.Address> recipients, ReplicableCommand command, org.jgroups.blocks.ResponseMode mode, long timeout, boolean anycasting, boolean oob, org.jgroups.blocks.RspFilter filter, boolean supportReplay, boolean asyncMarshalling) throws InterruptedException
recipients
- Guaranteed not to be null. Must not contain self.InterruptedException
public Response invokeRemoteCommand(org.jgroups.Address recipient, ReplicableCommand command, org.jgroups.blocks.ResponseMode mode, long timeout, boolean oob, boolean supportReplay, boolean asyncMarshalling) throws InterruptedException
InterruptedException
public org.jgroups.util.RspList<Object> broadcastRemoteCommands(ReplicableCommand command, org.jgroups.blocks.ResponseMode mode, long timeout, boolean anycasting, boolean oob, org.jgroups.blocks.RspFilter filter, boolean supportReplay, boolean asyncMarshalling) throws InterruptedException
InterruptedException
public Object handle(org.jgroups.Message req)
handle
in interface org.jgroups.blocks.RequestHandler
handle
in class org.jgroups.blocks.RpcDispatcher
Copyright © 2013 JBoss, a division of Red Hat. All Rights Reserved.