public class CommandAwareRpcDispatcher
extends org.jgroups.blocks.RpcDispatcher
ReplicableCommand
s.method_lookup, req_marshaller, rsp_marshaller, server_obj
async_anycasts, async_dispatching, async_multicasts, async_unicasts, channel, channel_listeners, corr, hardware_multicast_supported, local_addr, members, membership_listener, msg_listener, probe_handler, prot_adapter, req_handler, sync_anycasts, sync_multicasts, sync_unicasts
Constructor and Description |
---|
CommandAwareRpcDispatcher(org.jgroups.Channel channel,
JGroupsTransport transport,
ExecutorService asyncExecutor,
ExecutorService remoteCommandsExecutor,
InboundInvocationHandler inboundInvocationHandler,
GlobalComponentRegistry gcr,
BackupReceiverRepository backupReceiverRepository) |
Modifier and Type | Method and Description |
---|---|
org.jgroups.util.RspList<Object> |
broadcastRemoteCommands(ReplicableCommand command,
org.jgroups.blocks.ResponseMode mode,
long timeout,
boolean oob,
org.jgroups.blocks.RspFilter filter,
boolean asyncMarshalling,
boolean ignoreLeavers,
boolean totalOrder) |
protected static org.jgroups.Message |
constructMessage(org.jgroups.util.Buffer buf,
org.jgroups.Address recipient,
boolean oob,
org.jgroups.blocks.ResponseMode mode,
boolean rsvp,
boolean totalOrder) |
void |
handle(org.jgroups.Message req,
org.jgroups.blocks.Response response)
Message contains a Command.
|
Response |
invokeRemoteCommand(org.jgroups.Address recipient,
ReplicableCommand command,
org.jgroups.blocks.ResponseMode mode,
long timeout,
boolean oob,
boolean asyncMarshalling) |
org.jgroups.util.RspList<Object> |
invokeRemoteCommands(List<org.jgroups.Address> recipients,
ReplicableCommand command,
org.jgroups.blocks.ResponseMode mode,
long timeout,
boolean oob,
org.jgroups.blocks.RspFilter filter,
boolean asyncMarshalling,
boolean ignoreLeavers,
boolean totalOrder) |
String |
toString() |
callRemoteMethod, callRemoteMethod, callRemoteMethods, callRemoteMethods, callRemoteMethodsWithFuture, callRemoteMethodsWithFuture, callRemoteMethodWithFuture, callRemoteMethodWithFuture, correlatorStarted, getMarshaller, getMethodLookup, getName, getRequestMarshaller, getResponseMarshaller, getServerObject, handle, setMarshaller, setMethodLookup, setRequestMarshaller, setResponseMarshaller, setServerObject
addChannelListener, asyncDispatching, asyncDispatching, cast, cast, castMessage, castMessageWithFuture, castMessageWithFuture, channelClosed, channelConnected, channelDisconnected, createRequestCorrelator, done, getChannel, getMessageListener, getProtocolAdapter, handleUpEvent, installUpHandler, removeChannelListener, sendMessage, sendMessageWithFuture, sendMessageWithFuture, setChannel, setMembers, setMembershipListener, setMessageListener, setRequestHandler, start, stop
public CommandAwareRpcDispatcher(org.jgroups.Channel channel, JGroupsTransport transport, ExecutorService asyncExecutor, ExecutorService remoteCommandsExecutor, InboundInvocationHandler inboundInvocationHandler, GlobalComponentRegistry gcr, BackupReceiverRepository backupReceiverRepository)
public org.jgroups.util.RspList<Object> invokeRemoteCommands(List<org.jgroups.Address> recipients, ReplicableCommand command, org.jgroups.blocks.ResponseMode mode, long timeout, boolean oob, org.jgroups.blocks.RspFilter filter, boolean asyncMarshalling, boolean ignoreLeavers, boolean totalOrder) 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 asyncMarshalling) throws InterruptedException
InterruptedException
public org.jgroups.util.RspList<Object> broadcastRemoteCommands(ReplicableCommand command, org.jgroups.blocks.ResponseMode mode, long timeout, boolean oob, org.jgroups.blocks.RspFilter filter, boolean asyncMarshalling, boolean ignoreLeavers, boolean totalOrder) throws InterruptedException
InterruptedException
public void handle(org.jgroups.Message req, org.jgroups.blocks.Response response) throws Exception
handle
in interface org.jgroups.blocks.AsyncRequestHandler
handle
in class org.jgroups.blocks.MessageDispatcher
Exception
protected static org.jgroups.Message constructMessage(org.jgroups.util.Buffer buf, org.jgroups.Address recipient, boolean oob, org.jgroups.blocks.ResponseMode mode, boolean rsvp, boolean totalOrder)
Copyright © 2014 JBoss, a division of Red Hat. All Rights Reserved.