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:

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 inherited from class org.jgroups.blocks.RpcDispatcher

method_lookup, req_marshaller, rsp_marshaller, server_obj

Fields inherited from class org.jgroups.blocks.MessageDispatcher

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 Summary

Constructors

Constructor and Description
CommandAwareRpcDispatcher(org.jgroups.Channel channel, JGroupsTransport transport, ExecutorService asyncExecutor, ExecutorService remoteCommandsExecutor, InboundInvocationHandler inboundInvocationHandler, GlobalComponentRegistry gcr, BackupReceiverRepository backupReceiverRepository)

Method Summary

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

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, createRequestCorrelator, done, getChannel, getMessageListener, getProtocolAdapter, handleUpEvent, installUpHandler, removeChannelListener, sendMessage, sendMessageWithFuture, sendMessageWithFuture, setChannel, setMembers, setMembershipListener, setMessageListener, setRequestHandler, start, stop

Methods inherited from class java.lang.Object

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

Constructor Detail

CommandAwareRpcDispatcher

public CommandAwareRpcDispatcher(org.jgroups.Channel channel,
                                 JGroupsTransport transport,
                                 ExecutorService asyncExecutor,
                                 ExecutorService remoteCommandsExecutor,
                                 InboundInvocationHandler inboundInvocationHandler,
                                 GlobalComponentRegistry gcr,
                                 BackupReceiverRepository backupReceiverRepository)

Method Detail

invokeRemoteCommands

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

Parameters:

recipients - Guaranteed not to be null. Must not contain self.

Throws:

InterruptedException

invokeRemoteCommand

public Response invokeRemoteCommand(org.jgroups.Address recipient,
                                    ReplicableCommand command,
                                    org.jgroups.blocks.ResponseMode mode,
                                    long timeout,
                                    boolean oob,
                                    boolean asyncMarshalling)
                             throws InterruptedException

Throws:

InterruptedException

broadcastRemoteCommands

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

Throws:

InterruptedException

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,
                                                      boolean oob,
                                                      org.jgroups.blocks.ResponseMode mode,
                                                      boolean rsvp,
                                                      boolean totalOrder)