public class CommandAwareRpcDispatcher extends RpcDispatcher
ReplicableCommand
s.RpcDispatcher.Marshaller
method_lookup, req_marshaller, rsp_marshaller, server_obj
channel, channel_listeners, corr, hardware_multicast_supported, local_addr, members, membership_listener, msg_listener, prot_adapter, req_handler
Constructor and Description |
---|
CommandAwareRpcDispatcher(Channel channel,
JGroupsTransport transport,
ExecutorService asyncExecutor,
InboundInvocationHandler inboundInvocationHandler) |
Modifier and Type | Method and Description |
---|---|
RspList<Object> |
broadcastRemoteCommands(ReplicableCommand command,
ResponseMode mode,
long timeout,
boolean anycasting,
boolean oob,
RspFilter filter,
boolean asyncMarshalling) |
Object |
handle(Message req)
Message contains a Command.
|
Response |
invokeRemoteCommand(Address recipient,
ReplicableCommand command,
ResponseMode mode,
long timeout,
boolean oob,
boolean asyncMarshalling) |
RspList<Object> |
invokeRemoteCommands(List<Address> recipients,
ReplicableCommand command,
ResponseMode mode,
long timeout,
boolean anycasting,
boolean oob,
RspFilter filter,
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
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
channelClosed, channelConnected, channelDisconnected
public CommandAwareRpcDispatcher(Channel channel, JGroupsTransport transport, ExecutorService asyncExecutor, InboundInvocationHandler inboundInvocationHandler)
public RspList<Object> invokeRemoteCommands(List<Address> recipients, ReplicableCommand command, ResponseMode mode, long timeout, boolean anycasting, boolean oob, RspFilter filter, boolean asyncMarshalling) throws InterruptedException
recipients
- Guaranteed not to be null. Must not contain self.InterruptedException
public Response invokeRemoteCommand(Address recipient, ReplicableCommand command, ResponseMode mode, long timeout, boolean oob, boolean asyncMarshalling) throws InterruptedException
InterruptedException
public RspList<Object> broadcastRemoteCommands(ReplicableCommand command, ResponseMode mode, long timeout, boolean anycasting, boolean oob, RspFilter filter, boolean asyncMarshalling) throws InterruptedException
InterruptedException
public Object handle(Message req)
handle
in interface RequestHandler
handle
in class RpcDispatcher
Copyright © 2012 JBoss by Red Hat. All Rights Reserved.