com.caucho.message.nautilus
Class NautilusBroker

java.lang.Object
  extended by com.caucho.message.broker.AbstractMessageBroker
      extended by 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.


Constructor Summary
NautilusBroker()
           
 
Method Summary
 void close()
           
 BrokerReceiver createReceiver(java.lang.String name, DistributionMode distMode, java.util.Map<java.lang.String,java.lang.Object> nodeProperties, ReceiverMessageHandler handler)
           
 BrokerSender createSender(java.lang.String name, java.util.Map<java.lang.String,java.lang.Object> nodeProperties)
           
static NautilusBroker getCurrent()
           
 long getDequeueCount()
           
 long getEnqueueCount()
           
 int getSize()
           
 void init()
           
 void setPath(Path path)
           
 
Methods inherited from class com.caucho.message.broker.AbstractMessageBroker
registerSelf
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

NautilusBroker

public NautilusBroker()
Method Detail

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