net.metanotion.rpc
Class LocalMessageBusServer

java.lang.Object
  net.metanotion.rpc.LocalMessageBusServer

All Implemented Interfaces:

EndPointFactory

public final class LocalMessageBusServer
extends java.lang.Object
implements EndPointFactory

Constructor Summary

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

LocalMessageBusServer(java.util.List<java.lang.String> protocols, java.util.concurrent.ExecutorService pool)

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

Method Summary

EndPoint	newBindingEndPoint(ObserverFactory<MessageSocket> connectionHandler)
EndPoint	newConnectingEndPoint(ObserverFactory<MessageSocket> connectionHandler)

Methods inherited from class java.lang.Object

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

Constructor Detail

LocalMessageBusServer

public LocalMessageBusServer(java.util.List<java.lang.String> protocols)

LocalMessageBusServer

public LocalMessageBusServer(java.util.List<java.lang.String> protocols,
                             java.util.concurrent.ExecutorService pool)

LocalMessageBusServer

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

Method Detail

newBindingEndPoint

public EndPoint newBindingEndPoint(ObserverFactory<MessageSocket> connectionHandler)

Specified by:

newBindingEndPoint in interface EndPointFactory

newConnectingEndPoint

public EndPoint newConnectingEndPoint(ObserverFactory<MessageSocket> connectionHandler)

Specified by:

newConnectingEndPoint in interface EndPointFactory