public class CommandAwareRpcDispatcher
extends org.jgroups.blocks.RpcDispatcher
ReplicableCommand
s.Modifier and Type | Field and Description |
---|---|
static org.jgroups.util.RspList<Response> |
EMPTY_RESPONSES_LIST |
Constructor and Description |
---|
CommandAwareRpcDispatcher(org.jgroups.Channel channel,
JGroupsTransport transport,
InboundInvocationHandler globalHandler,
ScheduledExecutorService timeoutExecutor,
TimeService timeService) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
protected static org.jgroups.Message |
constructMessage(org.jgroups.util.Buffer buf,
org.jgroups.Address recipient,
org.jgroups.blocks.ResponseMode mode,
boolean rsvp,
DeliverOrder deliverOrder) |
protected org.jgroups.blocks.RequestCorrelator |
createRequestCorrelator(org.jgroups.stack.Protocol transport,
org.jgroups.blocks.RequestHandler handler,
org.jgroups.Address local_addr) |
void |
handle(org.jgroups.Message req,
org.jgroups.blocks.Response response)
Message contains a Command.
|
SingleResponseFuture |
invokeRemoteCommand(org.jgroups.Address recipient,
ReplicableCommand command,
org.jgroups.blocks.ResponseMode mode,
long timeout,
DeliverOrder deliverOrder) |
CompletableFuture<org.jgroups.util.RspList<Response>> |
invokeRemoteCommands(List<org.jgroups.Address> recipients,
ReplicableCommand command,
org.jgroups.blocks.ResponseMode mode,
long timeout,
org.jgroups.blocks.RspFilter filter,
DeliverOrder deliverOrder) |
<T> T |
rethrowAsCacheException(Throwable t) |
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, correlator, correlator, done, extendedStats, extendedStats, getChannel, getMessageListener, getProtocolAdapter, handleUpEvent, installUpHandler, removeChannelListener, rpcStats, sendMessage, sendMessageWithFuture, sendMessageWithFuture, setChannel, setMembers, setMembershipListener, setMessageListener, setRequestHandler, start, stop, wrapExceptions, wrapExceptions
public static final org.jgroups.util.RspList<Response> EMPTY_RESPONSES_LIST
public CommandAwareRpcDispatcher(org.jgroups.Channel channel, JGroupsTransport transport, InboundInvocationHandler globalHandler, ScheduledExecutorService timeoutExecutor, TimeService timeService)
public void close()
close
in interface Closeable
close
in interface AutoCloseable
close
in class org.jgroups.blocks.MessageDispatcher
protected org.jgroups.blocks.RequestCorrelator createRequestCorrelator(org.jgroups.stack.Protocol transport, org.jgroups.blocks.RequestHandler handler, org.jgroups.Address local_addr)
createRequestCorrelator
in class org.jgroups.blocks.MessageDispatcher
public CompletableFuture<org.jgroups.util.RspList<Response>> invokeRemoteCommands(List<org.jgroups.Address> recipients, ReplicableCommand command, org.jgroups.blocks.ResponseMode mode, long timeout, org.jgroups.blocks.RspFilter filter, DeliverOrder deliverOrder)
recipients
- Must not contain self.public SingleResponseFuture invokeRemoteCommand(org.jgroups.Address recipient, ReplicableCommand command, org.jgroups.blocks.ResponseMode mode, long timeout, DeliverOrder deliverOrder)
public <T> T rethrowAsCacheException(Throwable t)
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, org.jgroups.blocks.ResponseMode mode, boolean rsvp, DeliverOrder deliverOrder)
Copyright © 2017 JBoss, a division of Red Hat. All rights reserved.