Prev Class | Next Class | Frames | No Frames |
Summary: Nested | Field | Method | Constr | Detail: Nested | Field | Method | Constr |
java.lang.Object
org.jgroups.blocks.MessageDispatcher
org.jgroups.blocks.RpcDispatcher
Nested Class Summary | |
static interface |
Field Summary | |
protected RpcDispatcher.Marshaller | |
protected Object |
Fields inherited from class org.jgroups.blocks.MessageDispatcher | |
adapter , channel , concurrent_processing , corr , deadlock_detection , id , local_addr , log , members , membership_listener , msg_listener , prot_adapter , req_handler , transport_adapter |
Constructor Summary | |
| |
| |
| |
|
Method Summary | |
Object |
|
Object |
|
Object |
|
RspList |
|
RspList |
|
RspList |
|
RspList |
|
void |
|
void |
|
void |
|
void |
|
void | |
RpcDispatcher.Marshaller | |
String |
|
Object | |
Object |
|
void |
Methods inherited from class org.jgroups.blocks.MessageDispatcher | |
castMessage , castMessage , done , handle , send , sendMessage , setConcurrentProcessing , setDeadlockDetection , setMembershipListener , setMessageListener , setRequestHandler , start , stop |
public RpcDispatcher(Channel channel, MessageListener l, MembershipListener l2, Object server_obj)
public RpcDispatcher(Channel channel, MessageListener l, MembershipListener l2, Object server_obj, boolean deadlock_detection)
public RpcDispatcher(Channel channel, MessageListener l, MembershipListener l2, Object server_obj, boolean deadlock_detection, boolean concurrent_processing)
public RpcDispatcher(PullPushAdapter adapter, Serializable id, MessageListener l, MembershipListener l2, Object server_obj)
public Object callRemoteMethod(Address dest, String method_name, Object[] args, Class[] types, int mode, long timeout) throws TimeoutException, SuspectedException
public Object callRemoteMethod(Address dest, String method_name, Object[] args, String[] signature, int mode, long timeout) throws TimeoutException, SuspectedException
public Object callRemoteMethod(Address dest, MethodCall method_call, int mode, long timeout) throws TimeoutException, SuspectedException
public RspList callRemoteMethods(Vector dests, String method_name, Object[] args, Class[] types, int mode, long timeout)
public RspList callRemoteMethods(Vector dests, String method_name, Object[] args, String[] signature, int mode, long timeout)
public RspList callRemoteMethods(Vector dests, MethodCall method_call, int mode, long timeout)
public RspList castMessage(Vector dests, Message msg, int mode, long timeout)
- Overrides:
- castMessage in interface MessageDispatcher
public void channelClosed(Channel channel)
- Specified by:
- channelClosed in interface ChannelListener
public void channelConnected(Channel channel)
- Specified by:
- channelConnected in interface ChannelListener
public void channelDisconnected(Channel channel)
- Specified by:
- channelDisconnected in interface ChannelListener
public void channelReconnected(Address new_addr)
- Specified by:
- channelReconnected in interface ChannelListener
public String getName()
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 interface MessageDispatcher
public Object sendMessage(Message msg, int mode, long timeout) throws TimeoutException, SuspectedException
- Overrides:
- sendMessage in interface MessageDispatcher