public class MuxRpcDispatcher extends RpcDispatcher
Channel c = new JChannel(...);
c.setUpHandler(new MuxUpHandler());
RpcDispatcher d1 = new MuxRpcDispatcher((short) 1, c, ...);
RpcDispatcher d2 = new MuxRpcDispatcher((short) 2, c, ...);
c.connect(...);
RpcDispatcher.Marshaller, RpcDispatcher.Marshaller2, RpcDispatcher.MarshallerAdapter
additionalChannelListeners, method_lookup, req_marshaller, rsp_marshaller, 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 |
---|
MuxRpcDispatcher(short scopeId) |
MuxRpcDispatcher(short scopeId,
Channel channel,
MessageListener messageListener,
MembershipListener membershipListener,
Object serverObject) |
MuxRpcDispatcher(short scopeId,
Channel channel,
MessageListener messageListener,
MembershipListener membershipListener,
Object serverObject,
MethodLookup method_lookup) |
Modifier and Type | Method and Description |
---|---|
protected GroupRequest |
cast(Collection<Address> dests,
Message msg,
RequestOptions options,
boolean blockForResults) |
protected RequestCorrelator |
createRequestCorrelator(Object transport,
RequestHandler handler,
Address localAddr) |
void |
start() |
void |
stop() |
addChannelListener, callRemoteMethod, callRemoteMethod, callRemoteMethod, callRemoteMethod, callRemoteMethod, callRemoteMethod, callRemoteMethod, callRemoteMethods, callRemoteMethods, callRemoteMethods, callRemoteMethods, callRemoteMethods, callRemoteMethods, callRemoteMethods, callRemoteMethods, callRemoteMethodsWithFuture, callRemoteMethodsWithFuture, callRemoteMethodsWithFuture, callRemoteMethodWithFuture, callRemoteMethodWithFuture, callRemoteMethodWithFuture, channelClosed, channelConnected, channelDisconnected, channelReconnected, channelShunned, correlatorStarted, getMarshaller, getMethodLookup, getName, getRequestMarshaller, getResponseMarshaller, getServerObject, handle, removeChannelListener, setMarshaller, setMethodLookup, setRequestMarshaller, setResponseMarshaller, setServerObject
castMessage, castMessage, castMessage, castMessage, castMessageWithFuture, castMessageWithFuture, done, getChannel, getConcurrentProcessing, getDeadlockDetection, getMembers, getMessageListener, getProtocolAdapter, installUpHandler, send, sendMessage, sendMessage, sendMessageWithFuture, sendMessageWithFuture, setChannel, setConcurrentProcessing, setDeadlockDetection, setMembershipListener, setMessageListener, setRequestHandler
public MuxRpcDispatcher(short scopeId)
public MuxRpcDispatcher(short scopeId, Channel channel, MessageListener messageListener, MembershipListener membershipListener, Object serverObject)
public MuxRpcDispatcher(short scopeId, Channel channel, MessageListener messageListener, MembershipListener membershipListener, Object serverObject, MethodLookup method_lookup)
protected RequestCorrelator createRequestCorrelator(Object transport, RequestHandler handler, Address localAddr)
createRequestCorrelator
in class MessageDispatcher
public void start()
start
in class MessageDispatcher
public void stop()
stop
in class MessageDispatcher
protected GroupRequest cast(Collection<Address> dests, Message msg, RequestOptions options, boolean blockForResults)
cast
in class MessageDispatcher
Copyright © 2013 JBoss, a division of Red Hat. All Rights Reserved.