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

Method Summary

Modifier and Type	Method and Description
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