com.caucho.message.broker
Class AbstractMessageBroker

java.lang.Object
  extended by com.caucho.message.broker.AbstractMessageBroker
All Implemented Interfaces:
MessageBroker
Direct Known Subclasses:
NautilusBroker

public abstract class AbstractMessageBroker
extends java.lang.Object
implements MessageBroker

AbstractStompBroker with common routines for brokers.


Constructor Summary
AbstractMessageBroker()
           
 
Method Summary
 BrokerReceiver createReceiver(java.lang.String name, DistributionMode distMode, java.util.Map<java.lang.String,java.lang.Object> nodeProperties, ReceiverMessageHandler listener)
           
 BrokerSender createSender(java.lang.String name, java.util.Map<java.lang.String,java.lang.Object> nodeProperties)
           
protected  void registerSelf()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

AbstractMessageBroker

public AbstractMessageBroker()
Method Detail

createSender

public BrokerSender createSender(java.lang.String name,
                                 java.util.Map<java.lang.String,java.lang.Object> nodeProperties)
Specified by:
createSender in interface MessageBroker

createReceiver

public BrokerReceiver createReceiver(java.lang.String name,
                                     DistributionMode distMode,
                                     java.util.Map<java.lang.String,java.lang.Object> nodeProperties,
                                     ReceiverMessageHandler listener)
Specified by:
createReceiver in interface MessageBroker

registerSelf

protected void registerSelf()