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(...);
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 |
---|
MuxMessageDispatcher(short scopeId) |
MuxMessageDispatcher(short scopeId,
Channel channel,
MessageListener messageListener,
MembershipListener membershipListener,
RequestHandler handler) |
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() |
castMessage, castMessage, castMessage, castMessage, castMessageWithFuture, castMessageWithFuture, correlatorStarted, done, getChannel, getConcurrentProcessing, getDeadlockDetection, getMembers, getMessageListener, getProtocolAdapter, handle, installUpHandler, send, sendMessage, sendMessage, sendMessageWithFuture, sendMessageWithFuture, setChannel, setConcurrentProcessing, setDeadlockDetection, setMembershipListener, setMessageListener, setRequestHandler
public MuxMessageDispatcher(short scopeId)
public MuxMessageDispatcher(short scopeId, Channel channel, MessageListener messageListener, MembershipListener membershipListener, RequestHandler handler)
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.