com.caucho.message.broker
Class EnvironmentMessageBroker
java.lang.Object
com.caucho.message.broker.EnvironmentMessageBroker
- All Implemented Interfaces:
- MessageBroker
public class EnvironmentMessageBroker
- extends java.lang.Object
- implements MessageBroker
Custom serialization for the cache
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
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