org.jgroups.blocks
public class RpcDispatcher extends MessageDispatcher implements ChannelListener
Nested Class Summary | |
---|---|
interface | RpcDispatcher.Marshaller |
Field Summary | |
---|---|
protected List | additionalChannelListeners |
protected RpcDispatcher.Marshaller | marshaller |
protected MethodLookup | method_lookup |
protected Object | server_obj |
Constructor Summary | |
---|---|
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) | |
RpcDispatcher(PullPushAdapter adapter, Serializable id, MessageListener l, MembershipListener l2, Object server_obj) |
Method Summary | |
---|---|
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) |
RspList | callRemoteMethods(Vector dests, String method_name, Object[] args, Class[] types, int mode, long timeout) |
RspList | callRemoteMethods(Vector dests, String method_name, Object[] args, String[] signature, int mode, long timeout) |
RspList | callRemoteMethods(Vector dests, MethodCall method_call, int mode, long timeout) |
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() |
RpcDispatcher.Marshaller | getMarshaller() |
MethodLookup | getMethodLookup() |
String | getName() |
Object | getServerObject() |
Object | handle(Message req)
Message contains MethodCall. |
boolean | removeChannelListener(ChannelListener l) |
Object | sendMessage(Message msg, int mode, long timeout) |
void | setMarshaller(RpcDispatcher.Marshaller m) |
void | setMethodLookup(MethodLookup method_lookup) |
Returns: true if the listener was added or false if the listener was already in the list.
Returns: true if the channel was removed indeed.