com.fr.third.jgroups.blocks.mux

类 MuxMessageDispatcher

java.lang.Object

com.fr.third.jgroups.blocks.MessageDispatcher

com.fr.third.jgroups.blocks.mux.MuxMessageDispatcher

所有已实现的接口:

AsyncRequestHandler, RequestHandler, ChannelListener

public class MuxMessageDispatcher
extends MessageDispatcher

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());

MessageDispatcher d1 = new MuxMessageDispatcher((short) 1, c, ...);
MessageDispatcher d2 = new MuxMessageDispatcher((short) 2, c, ...);

c.connect(...);


作者:

Paul Ferraro

字段概要

从类继承的字段 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

构造器概要

构造器

构造器和说明
MuxMessageDispatcher(short scopeId)
MuxMessageDispatcher(short scopeId, Channel channel, MessageListener messageListener, MembershipListener membershipListener, RequestHandler handler)

方法概要

方法

限定符和类型	方法和说明
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.MessageDispatcher

addChannelListener, asyncDispatching, asyncDispatching, cast, castMessage, castMessageWithFuture, castMessageWithFuture, channelClosed, channelConnected, channelDisconnected, correlatorStarted, done, getChannel, getMessageListener, getProtocolAdapter, handle, 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

构造器详细资料

MuxMessageDispatcher

public MuxMessageDispatcher(short scopeId)

MuxMessageDispatcher

public MuxMessageDispatcher(short scopeId,
                    Channel channel,
                    MessageListener messageListener,
                    MembershipListener membershipListener,
                    RequestHandler handler)

方法详细资料

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