org.infinispan.remoting.transport.jgroups

Class CommandAwareRpcDispatcher

java.lang.Object

org.jgroups.blocks.MessageDispatcher

org.jgroups.blocks.RpcDispatcher

org.infinispan.remoting.transport.jgroups.CommandAwareRpcDispatcher

All Implemented Interfaces:

Closeable, AutoCloseable, org.jgroups.blocks.AsyncRequestHandler, org.jgroups.blocks.RequestHandler, org.jgroups.ChannelListener

public class CommandAwareRpcDispatcher
extends org.jgroups.blocks.RpcDispatcher

A JGroups RPC dispatcher that knows how to deal with ReplicableCommands.

Since:

4.0

Author:

Manik Surtani (manik@jboss.org), Pedro Ruivo

Nested Class Summary

Nested classes/interfaces inherited from class org.jgroups.blocks.RpcDispatcher

org.jgroups.blocks.RpcDispatcher.Marshaller

Field Summary

Fields

Modifier and Type	Field and Description
static org.jgroups.util.RspList<Response>	EMPTY_RESPONSES_LIST

Fields inherited from class org.jgroups.blocks.RpcDispatcher

method_lookup, req_marshaller, rsp_marshaller, server_obj

Fields inherited from class org.jgroups.blocks.MessageDispatcher

async_dispatching, channel, channel_listeners, corr, hardware_multicast_supported, local_addr, members, membership_listener, msg_listener, prot_adapter, req_handler, rpc_stats, wrap_exceptions

Constructor Summary

Constructors

Constructor and Description
CommandAwareRpcDispatcher(org.jgroups.Channel channel, JGroupsTransport transport, InboundInvocationHandler globalHandler, ScheduledExecutorService timeoutExecutor, TimeService timeService)

Method Summary

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()

Methods inherited from class org.jgroups.blocks.RpcDispatcher

callRemoteMethod, callRemoteMethod, callRemoteMethods, callRemoteMethods, callRemoteMethodsWithFuture, callRemoteMethodsWithFuture, callRemoteMethodWithFuture, callRemoteMethodWithFuture, correlatorStarted, getMarshaller, getMethodLookup, getName, getRequestMarshaller, getResponseMarshaller, getServerObject, handle, setMarshaller, setMethodLookup, setRequestMarshaller, setResponseMarshaller, setServerObject

Methods inherited from class org.jgroups.blocks.MessageDispatcher

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

EMPTY_RESPONSES_LIST

public static final org.jgroups.util.RspList<Response> EMPTY_RESPONSES_LIST

Constructor Detail

CommandAwareRpcDispatcher

public CommandAwareRpcDispatcher(org.jgroups.Channel channel,
                                 JGroupsTransport transport,
                                 InboundInvocationHandler globalHandler,
                                 ScheduledExecutorService timeoutExecutor,
                                 TimeService timeService)

Method Detail

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Overrides:

close in class org.jgroups.blocks.MessageDispatcher

createRequestCorrelator

protected org.jgroups.blocks.RequestCorrelator createRequestCorrelator(org.jgroups.stack.Protocol transport,
                                                                       org.jgroups.blocks.RequestHandler handler,
                                                                       org.jgroups.Address local_addr)

Overrides:

createRequestCorrelator in class org.jgroups.blocks.MessageDispatcher

invokeRemoteCommands

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)

Parameters:

recipients - Must not contain self.

invokeRemoteCommand

public SingleResponseFuture invokeRemoteCommand(org.jgroups.Address recipient,
                                                ReplicableCommand command,
                                                org.jgroups.blocks.ResponseMode mode,
                                                long timeout,
                                                DeliverOrder deliverOrder)

rethrowAsCacheException

public <T> T rethrowAsCacheException(Throwable t)

handle

public void handle(org.jgroups.Message req,
                   org.jgroups.blocks.Response response)
            throws Exception

Message contains a Command. Execute it against *this* object and return result.

Specified by:

handle in interface org.jgroups.blocks.AsyncRequestHandler

Overrides:

handle in class org.jgroups.blocks.MessageDispatcher

Throws:

Exception

toString

public String toString()

Overrides:

toString in class Object

constructMessage

protected static org.jgroups.Message constructMessage(org.jgroups.util.Buffer buf,
                                                      org.jgroups.Address recipient,
                                                      org.jgroups.blocks.ResponseMode mode,
                                                      boolean rsvp,
                                                      DeliverOrder deliverOrder)