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, java.lang.AutoCloseable

@Singleton
public class NautilusBroker
extends AbstractMessageBroker
implements java.io.Closeable

Simple stomp broker.

Constructor Summary

Constructors

Constructor and Description
NautilusBroker()

Method Summary

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

Specified by:

close in interface java.lang.AutoCloseable