org.jgroups.blocks.mux

Class MuxRpcDispatcher

java.lang.Object

org.jgroups.blocks.MessageDispatcher

org.jgroups.blocks.RpcDispatcher

org.jgroups.blocks.mux.MuxRpcDispatcher

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, 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:

 JChannel c = new JChannel(...);
 c.setUpHandler(new MuxUpHandler());

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

 c.connect(...);
 

Author:

Bela Ban, Paul Ferraro

Nested Class Summary

Nested classes/interfaces inherited from class org.jgroups.blocks.RpcDispatcher

RpcDispatcher.Marshaller

Field Summary

Fields inherited from class org.jgroups.blocks.RpcDispatcher

method_lookup, req_marshaller, rsp_marshaller, server_obj

Fields inherited from class org.jgroups.blocks.MessageDispatcher

async_dispatching, channel, channel_listeners, corr, hardware_multicast_supported, local_addr, log, members, membership_listener, msg_listener, prot_adapter, req_handler, rpc_stats, wrap_exceptions

Constructor Summary

Constructors

Constructor and Description
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)

Method Summary

Modifier and Type	Method and Description
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()

Methods inherited from class org.jgroups.blocks.RpcDispatcher

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

Methods inherited from class org.jgroups.blocks.MessageDispatcher

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

Methods inherited from class java.lang.Object

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

Constructor Detail

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)

Method Detail

createRequestCorrelator

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

Overrides:

createRequestCorrelator in class MessageDispatcher

start

public void start()

Overrides:

start in class MessageDispatcher

stop

public void stop()

Overrides:

stop in class 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

Overrides:

cast in class MessageDispatcher

Throws:

java.lang.Exception