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 MessageBroker
public BrokerReceiver createReceiver(java.lang.String name, DistributionMode distMode, java.util.Map<java.lang.String,java.lang.Object> nodeProperties, ReceiverMessageHandler listener)
createReceiver
in interface MessageBroker
protected void registerSelf()