public abstract class AbstractMessageBroker extends java.lang.Object implements MessageBroker
| Constructor and Description |
|---|
AbstractMessageBroker() |
| Modifier and Type | Method and Description |
|---|---|
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() |
public BrokerSender createSender(java.lang.String name, java.util.Map<java.lang.String,java.lang.Object> nodeProperties)
createSender in interface MessageBrokerpublic BrokerReceiver createReceiver(java.lang.String name, DistributionMode distMode, java.util.Map<java.lang.String,java.lang.Object> nodeProperties, ReceiverMessageHandler listener)
createReceiver in interface MessageBrokerprotected void registerSelf()