public class CommandAwareRpcDispatcher
extends org.jgroups.blocks.RpcDispatcher
ReplicableCommand
s.method_lookup, req_marshaller, rsp_marshaller, server_obj
async_anycasts, 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,
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 anycasting,
boolean oob,
org.jgroups.blocks.RspFilter filter,
boolean asyncMarshalling,
boolean ignoreLeavers) |
protected static org.jgroups.Message |
constructMessage(org.jgroups.util.Buffer buf,
org.jgroups.Address recipient,
boolean oob,
org.jgroups.blocks.ResponseMode mode,
boolean rsvp) |
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 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 asyncMarshalling,
boolean ignoreLeavers) |
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, handleUpEvent, installUpHandler, removeChannelListener, sendMessage, sendMessageWithFuture, setChannel, setMembers, setMembershipListener, setMessageListener, setRequestHandler, start, stop
public CommandAwareRpcDispatcher(org.jgroups.Channel channel, JGroupsTransport transport, ExecutorService asyncExecutor, 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 anycasting, boolean oob, org.jgroups.blocks.RspFilter filter, boolean asyncMarshalling, boolean ignoreLeavers) 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 anycasting, boolean oob, org.jgroups.blocks.RspFilter filter, boolean asyncMarshalling, boolean ignoreLeavers) throws InterruptedException
InterruptedException
public Object handle(org.jgroups.Message req)
handle
in interface org.jgroups.blocks.RequestHandler
handle
in class org.jgroups.blocks.RpcDispatcher
protected static org.jgroups.Message constructMessage(org.jgroups.util.Buffer buf, org.jgroups.Address recipient, boolean oob, org.jgroups.blocks.ResponseMode mode, boolean rsvp)
Copyright © 2017 JBoss, a division of Red Hat. All Rights Reserved.