Uses of Interface
net.metanotion.util.observers.MessageBusManager

Packages that use MessageBusManager

net.metanotion.rpc
net.metanotion.util.observers

Uses of MessageBusManager in net.metanotion.rpc

Constructors in net.metanotion.rpc with parameters of type MessageBusManager

LocalMessageBusServer(java.util.List<java.lang.String> protocols, MessageBusManager bus)

MINAEndPointFactory(IoService service, java.net.SocketAddress sa, int maxPacketSize, java.util.List<java.lang.String> protocols, MessageBusManager bus)

RPCIoHandler(MessageBusManager bus, ObserverFactory<IoSession> ofactory, SpecialMessages messageFactory)

RPCServer(IoService service, int maxPacketSize, java.util.List<java.lang.String> protocols, ObserverFactory<IoSession> factory, MessageBusManager bus)

Uses of MessageBusManager in net.metanotion.util.observers

Classes in net.metanotion.util.observers that implement MessageBusManager

class

ConcurrentMessageBusManager<M extends Message> An MessageBusManager that uses an ExecutorService for concurrent, asynchronous dispatching of events.

Constructors in net.metanotion.util.observers with parameters of type MessageBusManager

ChannelBusMessageOutputStream(java.lang.Object channel, MessageBusManager bus)