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:

RequestHandler, ChannelListener

public class CommandAwareRpcDispatcher
extends RpcDispatcher

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

Since:

4.0

Author:

Manik Surtani (manik@jboss.org)

Nested Class Summary

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

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

channel, channel_listeners, corr, hardware_multicast_supported, local_addr, members, membership_listener, msg_listener, prot_adapter, req_handler

Constructor Summary

Constructors

Constructor and Description
CommandAwareRpcDispatcher(Channel channel, JGroupsTransport transport, ExecutorService asyncExecutor, InboundInvocationHandler inboundInvocationHandler)

Method Summary

Methods

Modifier and Type	Method and Description
RspList<Object>	broadcastRemoteCommands(ReplicableCommand command, ResponseMode mode, long timeout, boolean anycasting, boolean oob, RspFilter filter, boolean asyncMarshalling)
Object	handle(Message req) Message contains a Command.
Response	invokeRemoteCommand(Address recipient, ReplicableCommand command, ResponseMode mode, long timeout, boolean oob, boolean asyncMarshalling)
RspList<Object>	invokeRemoteCommands(List<Address> recipients, ReplicableCommand command, ResponseMode mode, long timeout, boolean anycasting, boolean oob, RspFilter filter, boolean asyncMarshalling)
String	toString()

Methods inherited from class org.jgroups.blocks.RpcDispatcher

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

Methods inherited from class org.jgroups.blocks.MessageDispatcher

addChannelListener, cast, castMessage, castMessageWithFuture, channelClosed, channelConnected, channelDisconnected, createRequestCorrelator, done, getChannel, getMessageListener, getProtocolAdapter, installUpHandler, removeChannelListener, sendMessage, 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

Methods inherited from interface org.jgroups.ChannelListener

channelClosed, channelConnected, channelDisconnected

Constructor Detail

CommandAwareRpcDispatcher

public CommandAwareRpcDispatcher(Channel channel,
                         JGroupsTransport transport,
                         ExecutorService asyncExecutor,
                         InboundInvocationHandler inboundInvocationHandler)

Method Detail

invokeRemoteCommands

public RspList<Object> invokeRemoteCommands(List<Address> recipients,
                                   ReplicableCommand command,
                                   ResponseMode mode,
                                   long timeout,
                                   boolean anycasting,
                                   boolean oob,
                                   RspFilter filter,
                                   boolean asyncMarshalling)
                                     throws InterruptedException

Parameters:

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

Throws:

InterruptedException

invokeRemoteCommand

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

Throws:

InterruptedException

broadcastRemoteCommands

public RspList<Object> broadcastRemoteCommands(ReplicableCommand command,
                                      ResponseMode mode,
                                      long timeout,
                                      boolean anycasting,
                                      boolean oob,
                                      RspFilter filter,
                                      boolean asyncMarshalling)
                                        throws InterruptedException

Throws:

InterruptedException

handle

public Object handle(Message req)

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

Specified by:

handle in interface RequestHandler

Overrides:

handle in class RpcDispatcher

toString

public String toString()

Overrides:

toString in class Object