public class MuxMessageDispatcher extends MessageDispatcher
Channel c = new JChannel(...);
c.setUpHandler(new MuxUpHandler());
MessageDispatcher d1 = new MuxMessageDispatcher((short) 1, c, ...);
MessageDispatcher d2 = new MuxMessageDispatcher((short) 2, c, ...);
c.connect(...);
channel, channel_listeners, corr, hardware_multicast_supported, local_addr, log, members, membership_listener, msg_listener, prot_adapter, req_handler
Constructor and Description |
---|
MuxMessageDispatcher(short scopeId) |
MuxMessageDispatcher(short scopeId,
Channel channel,
MessageListener messageListener,
MembershipListener membershipListener,
RequestHandler handler) |
Modifier and Type | Method and Description |
---|---|
protected <T> GroupRequest<T> |
cast(Collection<Address> dests,
Message msg,
RequestOptions options,
boolean blockForResults) |
protected RequestCorrelator |
createRequestCorrelator(Protocol transport,
RequestHandler handler,
Address localAddr) |
void |
start() |
void |
stop() |
addChannelListener, castMessage, castMessageWithFuture, channelClosed, channelConnected, channelDisconnected, correlatorStarted, done, getChannel, getMessageListener, getProtocolAdapter, handle, installUpHandler, removeChannelListener, sendMessage, sendMessageWithFuture, setChannel, setMembers, setMembershipListener, setMessageListener, setRequestHandler
public MuxMessageDispatcher(short scopeId)
public MuxMessageDispatcher(short scopeId, Channel channel, MessageListener messageListener, MembershipListener membershipListener, RequestHandler handler)
protected RequestCorrelator createRequestCorrelator(Protocol transport, RequestHandler handler, Address localAddr)
createRequestCorrelator
in class MessageDispatcher
public void start()
start
in class MessageDispatcher
public void stop()
stop
in class MessageDispatcher
protected <T> GroupRequest<T> cast(Collection<Address> dests, Message msg, RequestOptions options, boolean blockForResults) throws Exception
cast
in class MessageDispatcher
Exception
Copyright © 2012 JBoss by Red Hat. All Rights Reserved.