com.fr.third.jgroups.blocks.mux

类 MuxRpcDispatcher

java.lang.Object

com.fr.third.jgroups.blocks.MessageDispatcher

com.fr.third.jgroups.blocks.RpcDispatcher

com.fr.third.jgroups.blocks.mux.MuxRpcDispatcher

所有已实现的接口:

AsyncRequestHandler, RequestHandler, ChannelListener

public class MuxRpcDispatcher
extends RpcDispatcher

A multiplexed message dispatcher. When used in conjunction with a MuxUpHandler, allows multiple dispatchers to use the same channel.
Usage:
Channel c = new JChannel(...);
c.setUpHandler(new MuxUpHandler());

RpcDispatcher d1 = new MuxRpcDispatcher((short) 1, c, ...);
RpcDispatcher d2 = new MuxRpcDispatcher((short) 2, c, ...);

c.connect(...);


作者:

Bela Ban, Paul Ferraro

嵌套类概要

从类继承的嵌套类/接口 com.fr.third.jgroups.blocks.RpcDispatcher

RpcDispatcher.Marshaller

字段概要

从类继承的字段 com.fr.third.jgroups.blocks.RpcDispatcher

method_lookup, req_marshaller, rsp_marshaller, server_obj

从类继承的字段 com.fr.third.jgroups.blocks.MessageDispatcher

async_anycasts, async_dispatching, async_multicasts, async_unicasts, channel, channel_listeners, corr, hardware_multicast_supported, local_addr, log, members, membership_listener, msg_listener, probe_handler, prot_adapter, req_handler, sync_anycasts, sync_multicasts, sync_unicasts

构造器概要

构造器

构造器和说明
MuxRpcDispatcher(short scopeId)
MuxRpcDispatcher(short scopeId, Channel channel, MessageListener messageListener, MembershipListener membershipListener, java.lang.Object serverObject)
MuxRpcDispatcher(short scopeId, Channel channel, MessageListener messageListener, MembershipListener membershipListener, java.lang.Object serverObject, MethodLookup method_lookup)

方法概要

方法

限定符和类型	方法和说明
protected <T> GroupRequest<T>	cast(java.util.Collection<Address> dests, Message msg, RequestOptions options, boolean blockForResults, FutureListener<RspList<T>> listener)
protected RequestCorrelator	createRequestCorrelator(Protocol transport, RequestHandler handler, Address localAddr)
void	start()
void	stop()

从类继承的方法 com.fr.third.jgroups.blocks.RpcDispatcher

callRemoteMethod, callRemoteMethod, callRemoteMethods, callRemoteMethods, callRemoteMethodsWithFuture, callRemoteMethodsWithFuture, callRemoteMethodWithFuture, callRemoteMethodWithFuture, correlatorStarted, getMarshaller, getMethodLookup, getName, getRequestMarshaller, getResponseMarshaller, getServerObject, handle, setMarshaller, setMethodLookup, setRequestMarshaller, setResponseMarshaller, setServerObject

从类继承的方法 com.fr.third.jgroups.blocks.MessageDispatcher

addChannelListener, asyncDispatching, asyncDispatching, cast, castMessage, castMessageWithFuture, castMessageWithFuture, channelClosed, channelConnected, channelDisconnected, done, getChannel, getMessageListener, getProtocolAdapter, handle, handleUpEvent, installUpHandler, removeChannelListener, sendMessage, sendMessageWithFuture, sendMessageWithFuture, setChannel, setMembers, setMembershipListener, setMessageListener, setRequestHandler

从类继承的方法 java.lang.Object

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

构造器详细资料

MuxRpcDispatcher

public MuxRpcDispatcher(short scopeId)

MuxRpcDispatcher

public MuxRpcDispatcher(short scopeId,
                Channel channel,
                MessageListener messageListener,
                MembershipListener membershipListener,
                java.lang.Object serverObject)

MuxRpcDispatcher

public MuxRpcDispatcher(short scopeId,
                Channel channel,
                MessageListener messageListener,
                MembershipListener membershipListener,
                java.lang.Object serverObject,
                MethodLookup method_lookup)

方法详细资料

createRequestCorrelator

protected RequestCorrelator createRequestCorrelator(Protocol transport,
                                        RequestHandler handler,
                                        Address localAddr)

覆盖:

createRequestCorrelator 在类中 MessageDispatcher

start

public void start()

覆盖:

start 在类中 MessageDispatcher

stop

public void stop()

覆盖:

stop 在类中 MessageDispatcher

cast

protected <T> GroupRequest<T> cast(java.util.Collection<Address> dests,
                       Message msg,
                       RequestOptions options,
                       boolean blockForResults,
                       FutureListener<RspList<T>> listener)
                        throws java.lang.Exception

覆盖:

cast 在类中 MessageDispatcher

抛出:

java.lang.Exception