org.apache.activemq.artemis.core.protocol.mqtt

Class MQTTSessionState.OutboundStore

java.lang.Object

org.apache.activemq.artemis.core.protocol.mqtt.MQTTSessionState.OutboundStore

Enclosing class:

MQTTSessionState

public class MQTTSessionState.OutboundStore
extends Object

Constructor Summary

Constructors

Constructor and Description
OutboundStore()

Method Summary

Modifier and Type	Method and Description
int	generateMqttId(long serverId, long consumerId)
void	publish(int mqtt, long serverId, long consumerId)
org.apache.activemq.artemis.api.core.Pair<Long,Long>	publishAckd(int mqtt)
org.apache.activemq.artemis.api.core.Pair<Long,Long>	publishComplete(int mqtt)
org.apache.activemq.artemis.api.core.Pair<Long,Long>	publishReceived(int mqtt)

Methods inherited from class java.lang.Object

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

Constructor Detail

OutboundStore

public OutboundStore()

Method Detail

generateMqttId

public int generateMqttId(long serverId,
                          long consumerId)

publish

public void publish(int mqtt,
                    long serverId,
                    long consumerId)

publishAckd

public org.apache.activemq.artemis.api.core.Pair<Long,Long> publishAckd(int mqtt)

publishReceived

public org.apache.activemq.artemis.api.core.Pair<Long,Long> publishReceived(int mqtt)

publishComplete

public org.apache.activemq.artemis.api.core.Pair<Long,Long> publishComplete(int mqtt)