public class RpcDispatcher extends MessageDispatcher implements ChannelListener
Modifier and Type | Class and Description |
---|---|
static interface |
RpcDispatcher.Marshaller |
static interface |
RpcDispatcher.Marshaller2 |
static class |
RpcDispatcher.MarshallerAdapter
Used to provide a Marshaller2 interface to a Marshaller.
|
Modifier and Type | Field and Description |
---|---|
protected List<ChannelListener> |
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 |
adapter, channel, corr, handler, hardware_multicast_supported, id, local_addr, log, members, membership_listener, msg_listener, prot_adapter, req_handler, transport_adapter
Constructor and Description |
---|
RpcDispatcher() |
RpcDispatcher(Channel channel,
MessageListener l,
MembershipListener l2,
Object server_obj) |
RpcDispatcher(Channel channel,
MessageListener l,
MembershipListener l2,
Object server_obj,
boolean deadlock_detection)
Deprecated.
|
RpcDispatcher(Channel channel,
MessageListener l,
MembershipListener l2,
Object server_obj,
boolean deadlock_detection,
boolean concurrent_processing)
Deprecated.
|
RpcDispatcher(PullPushAdapter adapter,
Serializable id,
MessageListener l,
MembershipListener l2,
Object server_obj)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
boolean |
addChannelListener(ChannelListener l)
Add a new channel listener to be notified on the channel's state change.
|
Object |
callRemoteMethod(Address dest,
MethodCall call)
Deprecated.
|
Object |
callRemoteMethod(Address dest,
MethodCall method_call,
int mode,
long timeout)
Deprecated.
|
Object |
callRemoteMethod(Address dest,
MethodCall method_call,
int mode,
long timeout,
boolean oob)
Deprecated.
|
Object |
callRemoteMethod(Address dest,
MethodCall call,
RequestOptions options) |
Object |
callRemoteMethod(Address dest,
String method_name,
Object[] args,
Class[] types,
int mode,
long timeout)
Deprecated.
|
Object |
callRemoteMethod(Address dest,
String method_name,
Object[] args,
Class[] types,
RequestOptions options) |
Object |
callRemoteMethod(Address dest,
String method_name,
Object[] args,
String[] signature,
int mode,
long timeout)
Deprecated.
|
RspList |
callRemoteMethods(Collection<Address> dests,
MethodCall method_call,
RequestOptions options)
Invokes a method in all members contained in dests (or all members if dests is null).
|
RspList |
callRemoteMethods(Collection<Address> dests,
String method_name,
Object[] args,
Class[] types,
RequestOptions options) |
RspList |
callRemoteMethods(Vector<Address> dests,
MethodCall method_call,
int mode,
long timeout)
Deprecated.
|
RspList |
callRemoteMethods(Vector<Address> dests,
String method_name,
Object[] args,
Class[] types,
int mode,
long timeout)
Deprecated.
|
RspList |
callRemoteMethods(Vector<Address> dests,
String method_name,
Object[] args,
Class[] types,
int mode,
long timeout,
boolean use_anycasting)
Deprecated.
|
RspList |
callRemoteMethods(Vector<Address> dests,
String method_name,
Object[] args,
Class[] types,
int mode,
long timeout,
boolean use_anycasting,
RspFilter filter)
Deprecated.
|
RspList |
callRemoteMethods(Vector<Address> dests,
String method_name,
Object[] args,
String[] signature,
int mode,
long timeout)
Deprecated.
|
RspList |
callRemoteMethods(Vector<Address> dests,
String method_name,
Object[] args,
String[] signature,
int mode,
long timeout,
boolean use_anycasting)
Deprecated.
|
NotifyingFuture<RspList> |
callRemoteMethodsWithFuture(Collection<Address> dests,
MethodCall method_call,
RequestOptions options) |
NotifyingFuture<RspList> |
callRemoteMethodsWithFuture(Vector<Address> dests,
MethodCall method_call)
Deprecated.
|
NotifyingFuture<RspList> |
callRemoteMethodsWithFuture(Vector<Address> dests,
MethodCall method_call,
int mode,
long timeout,
boolean use_anycasting,
boolean oob,
RspFilter filter)
Deprecated.
|
<T> NotifyingFuture<T> |
callRemoteMethodWithFuture(Address dest,
MethodCall call)
Deprecated.
|
<T> NotifyingFuture<T> |
callRemoteMethodWithFuture(Address dest,
MethodCall method_call,
int mode,
long timeout,
boolean oob)
Deprecated.
|
<T> NotifyingFuture<T> |
callRemoteMethodWithFuture(Address dest,
MethodCall call,
RequestOptions options) |
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() |
static String |
getName() |
RpcDispatcher.Marshaller |
getRequestMarshaller() |
RpcDispatcher.Marshaller |
getResponseMarshaller() |
Object |
getServerObject() |
Object |
handle(Message req)
Message contains MethodCall.
|
boolean |
removeChannelListener(ChannelListener l) |
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) |
cast, castMessage, castMessage, castMessage, castMessage, castMessageWithFuture, castMessageWithFuture, createRequestCorrelator, done, getChannel, getConcurrentProcessing, getDeadlockDetection, getMembers, getMessageListener, getProtocolAdapter, installUpHandler, send, sendMessage, sendMessage, sendMessageWithFuture, sendMessageWithFuture, setChannel, setConcurrentProcessing, setDeadlockDetection, setMembershipListener, setMessageListener, setRequestHandler, start, stop
protected Object server_obj
protected RpcDispatcher.Marshaller2 req_marshaller
protected RpcDispatcher.Marshaller2 rsp_marshaller
protected final List<ChannelListener> additionalChannelListeners
protected MethodLookup method_lookup
public RpcDispatcher()
public RpcDispatcher(Channel channel, MessageListener l, MembershipListener l2, Object server_obj)
@Deprecated public RpcDispatcher(Channel channel, MessageListener l, MembershipListener l2, Object server_obj, boolean deadlock_detection)
@Deprecated public RpcDispatcher(Channel channel, MessageListener l, MembershipListener l2, Object server_obj, boolean deadlock_detection, boolean concurrent_processing)
@Deprecated public RpcDispatcher(PullPushAdapter adapter, Serializable id, MessageListener l, MembershipListener l2, Object server_obj)
public static String getName()
public RpcDispatcher.Marshaller getRequestMarshaller()
public void setRequestMarshaller(RpcDispatcher.Marshaller m)
public RpcDispatcher.Marshaller getResponseMarshaller()
public void setResponseMarshaller(RpcDispatcher.Marshaller m)
public RpcDispatcher.Marshaller getMarshaller()
public void setMarshaller(RpcDispatcher.Marshaller m)
public Object getServerObject()
public void setServerObject(Object server_obj)
public MethodLookup getMethodLookup()
public void setMethodLookup(MethodLookup method_lookup)
@Deprecated public RspList callRemoteMethods(Vector<Address> dests, String method_name, Object[] args, Class[] types, int mode, long timeout)
@Deprecated public RspList callRemoteMethods(Vector<Address> dests, String method_name, Object[] args, Class[] types, int mode, long timeout, boolean use_anycasting)
@Deprecated public RspList callRemoteMethods(Vector<Address> dests, String method_name, Object[] args, Class[] types, int mode, long timeout, boolean use_anycasting, RspFilter filter)
public RspList callRemoteMethods(Collection<Address> dests, String method_name, Object[] args, Class[] types, RequestOptions options)
@Deprecated public RspList callRemoteMethods(Vector<Address> dests, String method_name, Object[] args, String[] signature, int mode, long timeout)
@Deprecated public RspList callRemoteMethods(Vector<Address> dests, String method_name, Object[] args, String[] signature, int mode, long timeout, boolean use_anycasting)
@Deprecated public RspList callRemoteMethods(Vector<Address> dests, MethodCall method_call, int mode, long timeout)
public RspList callRemoteMethods(Collection<Address> dests, MethodCall method_call, RequestOptions options)
dests
- A list of addresses. If null, the method will be invoked on all cluster membersmethod_call
- The method (plus args) to be invokedoptions
- A collection of call options, e.g. sync versus async, timeout etc@Deprecated public NotifyingFuture<RspList> callRemoteMethodsWithFuture(Vector<Address> dests, MethodCall method_call, int mode, long timeout, boolean use_anycasting, boolean oob, RspFilter filter)
@Deprecated public NotifyingFuture<RspList> callRemoteMethodsWithFuture(Vector<Address> dests, MethodCall method_call)
public NotifyingFuture<RspList> callRemoteMethodsWithFuture(Collection<Address> dests, MethodCall method_call, RequestOptions options)
@Deprecated public Object callRemoteMethod(Address dest, String method_name, Object[] args, Class[] types, int mode, long timeout) throws Throwable
Throwable
public Object callRemoteMethod(Address dest, String method_name, Object[] args, Class[] types, RequestOptions options) throws Throwable
Throwable
@Deprecated public Object callRemoteMethod(Address dest, String method_name, Object[] args, String[] signature, int mode, long timeout) throws Throwable
Throwable
@Deprecated public Object callRemoteMethod(Address dest, MethodCall method_call, int mode, long timeout) throws Throwable
Throwable
@Deprecated public Object callRemoteMethod(Address dest, MethodCall method_call, int mode, long timeout, boolean oob) throws Throwable
Throwable
@Deprecated public Object callRemoteMethod(Address dest, MethodCall call) throws Throwable
Throwable
public Object callRemoteMethod(Address dest, MethodCall call, RequestOptions options) throws Throwable
Throwable
@Deprecated public <T> NotifyingFuture<T> callRemoteMethodWithFuture(Address dest, MethodCall method_call, int mode, long timeout, boolean oob) throws Throwable
Throwable
@Deprecated public <T> NotifyingFuture<T> callRemoteMethodWithFuture(Address dest, MethodCall call) throws Throwable
Throwable
public <T> NotifyingFuture<T> callRemoteMethodWithFuture(Address dest, MethodCall call, RequestOptions options) throws Throwable
Throwable
protected void correlatorStarted()
correlatorStarted
in class MessageDispatcher
public Object handle(Message req)
handle
in interface RequestHandler
handle
in class MessageDispatcher
public boolean addChannelListener(ChannelListener l)
public boolean removeChannelListener(ChannelListener l)
public void channelConnected(Channel channel)
channelConnected
in interface ChannelListener
public void channelDisconnected(Channel channel)
channelDisconnected
in interface ChannelListener
public void channelClosed(Channel channel)
channelClosed
in interface ChannelListener
public void channelShunned()
channelShunned
in interface ChannelListener
public void channelReconnected(Address new_addr)
channelReconnected
in interface ChannelListener
Copyright © 2013 JBoss, a division of Red Hat. All Rights Reserved.