com.caucho.message.nautilus
Class NautilusBroker
java.lang.Object
com.caucho.message.broker.AbstractMessageBroker
com.caucho.message.nautilus.NautilusBroker
- All Implemented Interfaces:
- MessageBroker, java.io.Closeable
@Singleton
public class NautilusBroker
- extends AbstractMessageBroker
- implements java.io.Closeable
Simple stomp broker.
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
NautilusBroker
public NautilusBroker()
setPath
public void setPath(Path path)
init
@PostConstruct
public void init()
getCurrent
public static NautilusBroker getCurrent()
createSender
public BrokerSender createSender(java.lang.String name,
java.util.Map<java.lang.String,java.lang.Object> nodeProperties)
- Specified by:
createSender
in interface MessageBroker
- Overrides:
createSender
in class AbstractMessageBroker
createReceiver
public BrokerReceiver createReceiver(java.lang.String name,
DistributionMode distMode,
java.util.Map<java.lang.String,java.lang.Object> nodeProperties,
ReceiverMessageHandler handler)
- Specified by:
createReceiver
in interface MessageBroker
- Overrides:
createReceiver
in class AbstractMessageBroker
getSize
public int getSize()
getEnqueueCount
public long getEnqueueCount()
getDequeueCount
public long getDequeueCount()
close
public void close()
- Specified by:
close
in interface java.io.Closeable