com.caucho.message.broker
Class EnvironmentMessageBroker

java.lang.Object
  extended by com.caucho.message.broker.EnvironmentMessageBroker
All Implemented Interfaces:
MessageBroker

public class EnvironmentMessageBroker
extends java.lang.Object
implements MessageBroker

Custom serialization for the cache


Method Summary
 void addBroker(MessageBroker broker)
           
static EnvironmentMessageBroker create()
           
 BrokerReceiver createReceiver(java.lang.String name, DistributionMode distributionMode, java.util.Map<java.lang.String,java.lang.Object> properties, ReceiverMessageHandler listener)
           
 BrokerSender createSender(java.lang.String name, java.util.Map<java.lang.String,java.lang.Object> properties)
           
 MessageBroker findBroker(java.lang.Class<?> brokerClass)
           
static EnvironmentMessageBroker getCurrent()
           
 void removeBroker(MessageBroker broker)
           
 java.lang.String toString()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Method Detail

getCurrent

public static EnvironmentMessageBroker getCurrent()

create

public static EnvironmentMessageBroker create()

addBroker

public void addBroker(MessageBroker broker)

removeBroker

public void removeBroker(MessageBroker broker)

findBroker

public MessageBroker findBroker(java.lang.Class<?> brokerClass)

createSender

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

createReceiver

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

toString

public java.lang.String toString()
Overrides:
toString in class java.lang.Object