org.apache.activemq.transport.mqtt

Class MQTTRetainedMessages

java.lang.Object

org.apache.activemq.util.ServiceSupport

org.apache.activemq.transport.mqtt.MQTTRetainedMessages

All Implemented Interfaces:

Service

public class MQTTRetainedMessages
extends ServiceSupport

Method Summary

Methods

Modifier and Type	Method and Description
void	addMessage(ActiveMQTopic dest, org.fusesource.mqtt.codec.PUBLISH publish)
protected void	doStart()
protected void	doStop(ServiceStopper stopper)
java.util.Set<org.fusesource.mqtt.codec.PUBLISH>	getMessages(ActiveMQTopic topic)
static MQTTRetainedMessages	getMQTTRetainedMessages(BrokerService broker)

Methods inherited from class org.apache.activemq.util.ServiceSupport

addServiceListener, dispose, isStarted, isStopped, isStopping, postStop, preStart, removeServiceListener, start, stop

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

doStop

protected void doStop(ServiceStopper stopper)
               throws java.lang.Exception

Specified by:

doStop in class ServiceSupport

Throws:

java.lang.Exception

doStart

protected void doStart()
                throws java.lang.Exception

Specified by:

doStart in class ServiceSupport

Throws:

java.lang.Exception

addMessage

public void addMessage(ActiveMQTopic dest,
              org.fusesource.mqtt.codec.PUBLISH publish)

getMessages

public java.util.Set<org.fusesource.mqtt.codec.PUBLISH> getMessages(ActiveMQTopic topic)

getMQTTRetainedMessages

public static MQTTRetainedMessages getMQTTRetainedMessages(BrokerService broker)