Package org.jgroups.blocks

Class RpcDispatcher

java.lang.Object

org.jgroups.blocks.MessageDispatcher

org.jgroups.blocks.RpcDispatcher

All Implemented Interfaces:

RequestHandler, ChannelListener

public class RpcDispatcher
extends MessageDispatcher
implements ChannelListener

This class allows a programmer to invoke remote methods in all (or single) group members and optionally wait for the return value(s). An application will typically create a channel and layer the RpcDispatcher building block on top of it, which allows it to dispatch remote methods (client role) and at the same time be called by other members (server role). This class is derived from MessageDispatcher. Is the equivalent of RpcProtocol on the application rather than protocol level.

Author:

Bela Ban

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	RpcDispatcher.Marshaller
static interface	RpcDispatcher.Marshaller2
static class	RpcDispatcher.MarshallerAdapter	Used to provide a Marshaller2 interface to a Marshaller.

Field Summary

Fields

Modifier and Type	Field	Description
protected final List	additionalChannelListeners
protected MethodLookup	method_lookup
protected RpcDispatcher.Marshaller2	req_marshaller	Marshaller to marshall requests at the caller and unmarshal requests at the receiver(s)
protected RpcDispatcher.Marshaller2	rsp_marshaller	Marshaller to marshal responses at the receiver(s) and unmarshal responses at the caller
protected Object	server_obj

Fields inherited from class org.jgroups.blocks.MessageDispatcher

adapter, channel, concurrent_processing, corr, deadlock_detection, handler, id, local_addr, log, members, membership_listener, msg_listener, prot_adapter, req_handler, transport_adapter

Constructor Summary

Constructors

Constructor	Description
RpcDispatcher()
RpcDispatcher(PullPushAdapter adapter, Serializable id, MessageListener l, MembershipListener l2, Object server_obj)
RpcDispatcher(Channel channel, MessageListener l, MembershipListener l2, Object server_obj)
RpcDispatcher(Channel channel, MessageListener l, MembershipListener l2, Object server_obj, boolean deadlock_detection)
RpcDispatcher(Channel channel, MessageListener l, MembershipListener l2, Object server_obj, boolean deadlock_detection, boolean concurrent_processing)

Method Summary

Modifier and Type	Method	Description
boolean	addChannelListener(ChannelListener l)	Add a new channel listener to be notified on the channel's state change.
Object	callRemoteMethod(Address dest, String method_name, Object[] args, Class[] types, int mode, long timeout)
Object	callRemoteMethod(Address dest, String method_name, Object[] args, String[] signature, int mode, long timeout)
Object	callRemoteMethod(Address dest, MethodCall method_call, int mode, long timeout)
Object	callRemoteMethod(Address dest, MethodCall method_call, int mode, long timeout, boolean oob)
RspList	callRemoteMethods(Vector dests, String method_name, Object[] args, Class[] types, int mode, long timeout)
RspList	callRemoteMethods(Vector dests, String method_name, Object[] args, Class[] types, int mode, long timeout, boolean use_anycasting)
RspList	callRemoteMethods(Vector dests, String method_name, Object[] args, Class[] types, int mode, long timeout, boolean use_anycasting, RspFilter filter)
RspList	callRemoteMethods(Vector dests, String method_name, Object[] args, String[] signature, int mode, long timeout)
RspList	callRemoteMethods(Vector dests, String method_name, Object[] args, String[] signature, int mode, long timeout, boolean use_anycasting)
RspList	callRemoteMethods(Vector dests, MethodCall method_call, int mode, long timeout)
RspList	callRemoteMethods(Vector dests, MethodCall method_call, int mode, long timeout, boolean use_anycasting)
RspList	callRemoteMethods(Vector dests, MethodCall method_call, int mode, long timeout, boolean use_anycasting, boolean oob)
RspList	callRemoteMethods(Vector dests, MethodCall method_call, int mode, long timeout, boolean use_anycasting, boolean oob, RspFilter filter)
RspList	castMessage(Vector dests, Message msg, int mode, long timeout)
void	channelClosed(Channel channel)
void	channelConnected(Channel channel)
void	channelDisconnected(Channel channel)
void	channelReconnected(Address new_addr)
void	channelShunned()
protected void	correlatorStarted()
RpcDispatcher.Marshaller	getMarshaller()
MethodLookup	getMethodLookup()
String	getName()
RpcDispatcher.Marshaller	getRequestMarshaller()
RpcDispatcher.Marshaller	getResponseMarshaller()
Object	getServerObject()
Object	handle(Message req)	Message contains MethodCall.
boolean	removeChannelListener(ChannelListener l)
Object	sendMessage(Message msg, int mode, long timeout)	Sends a message to a single member (destination = msg.dest) and returns the response.
void	setMarshaller(RpcDispatcher.Marshaller m)
void	setMethodLookup(MethodLookup method_lookup)
void	setRequestMarshaller(RpcDispatcher.Marshaller m)
void	setResponseMarshaller(RpcDispatcher.Marshaller m)
void	setServerObject(Object server_obj)

Methods inherited from class org.jgroups.blocks.MessageDispatcher

castMessage, castMessage, castMessage, done, getChannel, getConcurrentProcessing, getDeadlockDetection, getMembers, getMessageListener, send, setChannel, setConcurrentProcessing, setDeadlockDetection, setMembershipListener, setMessageListener, setRequestHandler, start, stop

Methods inherited from class java.lang.Object

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

Field Details

server_obj

protected Object server_obj

req_marshaller

protected RpcDispatcher.Marshaller2 req_marshaller

Marshaller to marshall requests at the caller and unmarshal requests at the receiver(s)

rsp_marshaller

protected RpcDispatcher.Marshaller2 rsp_marshaller

Marshaller to marshal responses at the receiver(s) and unmarshal responses at the caller

additionalChannelListeners

protected final List additionalChannelListeners

method_lookup

protected MethodLookup method_lookup

Constructor Details

RpcDispatcher

public RpcDispatcher()

RpcDispatcher

public RpcDispatcher(Channel channel,
 MessageListener l,
 MembershipListener l2,
 Object server_obj)

RpcDispatcher

public RpcDispatcher(Channel channel,
 MessageListener l,
 MembershipListener l2,
 Object server_obj,
 boolean deadlock_detection)

RpcDispatcher

public RpcDispatcher(Channel channel,
 MessageListener l,
 MembershipListener l2,
 Object server_obj,
 boolean deadlock_detection,
 boolean concurrent_processing)

RpcDispatcher

public RpcDispatcher(PullPushAdapter adapter,
 Serializable id,
 MessageListener l,
 MembershipListener l2,
 Object server_obj)

Method Details

getName

public String getName()

getRequestMarshaller

public RpcDispatcher.Marshaller getRequestMarshaller()

setRequestMarshaller

public void setRequestMarshaller(RpcDispatcher.Marshaller m)

getResponseMarshaller

public RpcDispatcher.Marshaller getResponseMarshaller()

setResponseMarshaller

public void setResponseMarshaller(RpcDispatcher.Marshaller m)

getMarshaller

public RpcDispatcher.Marshaller getMarshaller()

setMarshaller

public void setMarshaller(RpcDispatcher.Marshaller m)

getServerObject

public Object getServerObject()

setServerObject

public void setServerObject(Object server_obj)

getMethodLookup

public MethodLookup getMethodLookup()

setMethodLookup

public void setMethodLookup(MethodLookup method_lookup)

castMessage

public RspList castMessage(Vector dests,
 Message msg,
 int mode,
 long timeout)

Overrides:

castMessage in class MessageDispatcher

sendMessage

public Object sendMessage(Message msg,
 int mode,
 long timeout)
                   throws TimeoutException,
SuspectedException

Description copied from class: MessageDispatcher

Sends a message to a single member (destination = msg.dest) and returns the response. The message's destination must be non-zero !

Overrides:

sendMessage in class MessageDispatcher

Throws:

TimeoutException

SuspectedException

callRemoteMethods

public RspList callRemoteMethods(Vector dests,
 String method_name,
 Object[] args,
 Class[] types,
 int mode,
 long timeout)

callRemoteMethods

public RspList callRemoteMethods(Vector dests,
 String method_name,
 Object[] args,
 Class[] types,
 int mode,
 long timeout,
 boolean use_anycasting)

callRemoteMethods

public RspList callRemoteMethods(Vector dests,
 String method_name,
 Object[] args,
 Class[] types,
 int mode,
 long timeout,
 boolean use_anycasting,
 RspFilter filter)

callRemoteMethods

public RspList callRemoteMethods(Vector dests,
 String method_name,
 Object[] args,
 String[] signature,
 int mode,
 long timeout)

callRemoteMethods

public RspList callRemoteMethods(Vector dests,
 String method_name,
 Object[] args,
 String[] signature,
 int mode,
 long timeout,
 boolean use_anycasting)

callRemoteMethods

public RspList callRemoteMethods(Vector dests,
 MethodCall method_call,
 int mode,
 long timeout)

callRemoteMethods

public RspList callRemoteMethods(Vector dests,
 MethodCall method_call,
 int mode,
 long timeout,
 boolean use_anycasting)

callRemoteMethods

public RspList callRemoteMethods(Vector dests,
 MethodCall method_call,
 int mode,
 long timeout,
 boolean use_anycasting,
 boolean oob)

callRemoteMethods

public RspList callRemoteMethods(Vector dests,
 MethodCall method_call,
 int mode,
 long timeout,
 boolean use_anycasting,
 boolean oob,
 RspFilter filter)

callRemoteMethod

public Object callRemoteMethod(Address dest,
 String method_name,
 Object[] args,
 Class[] types,
 int mode,
 long timeout)
                        throws Throwable

Throws:

Throwable

callRemoteMethod

public Object callRemoteMethod(Address dest,
 String method_name,
 Object[] args,
 String[] signature,
 int mode,
 long timeout)
                        throws Throwable

Throws:

Throwable

callRemoteMethod

public Object callRemoteMethod(Address dest,
 MethodCall method_call,
 int mode,
 long timeout)
                        throws Throwable

Throws:

Throwable

callRemoteMethod

public Object callRemoteMethod(Address dest,
 MethodCall method_call,
 int mode,
 long timeout,
 boolean oob)
                        throws Throwable

Throws:

Throwable

correlatorStarted

protected void correlatorStarted()

Overrides:

correlatorStarted in class MessageDispatcher

handle

public Object handle(Message req)

Message contains MethodCall. Execute it against *this* object and return result. Use MethodCall.invoke() to do this. Return result.

Specified by:

handle in interface RequestHandler

Overrides:

handle in class MessageDispatcher

addChannelListener

public boolean addChannelListener(ChannelListener l)

Add a new channel listener to be notified on the channel's state change.

Returns:

true if the listener was added or false if the listener was already in the list.

removeChannelListener

public boolean removeChannelListener(ChannelListener l)

Returns:

true if the channel was removed indeed.

channelConnected

public void channelConnected(Channel channel)

Specified by:

channelConnected in interface ChannelListener

channelDisconnected

public void channelDisconnected(Channel channel)

Specified by:

channelDisconnected in interface ChannelListener

channelClosed

public void channelClosed(Channel channel)

Specified by:

channelClosed in interface ChannelListener

channelShunned

public void channelShunned()

Specified by:

channelShunned in interface ChannelListener

channelReconnected

public void channelReconnected(Address new_addr)

Specified by:

channelReconnected in interface ChannelListener