public class MQTTPacketIdGenerator extends ServiceSupport
Modifier and Type | Method and Description |
---|---|
void |
ackPacketId(String clientId,
short packetId) |
protected void |
doStart() |
protected void |
doStop(ServiceStopper stopper) |
static MQTTPacketIdGenerator |
getMQTTPacketIdGenerator(BrokerService broker) |
short |
getNextSequenceId(String clientId) |
short |
setPacketId(String clientId,
MQTTSubscription subscription,
ActiveMQMessage message,
org.fusesource.mqtt.codec.PUBLISH publish) |
void |
startClientSession(String clientId) |
boolean |
stopClientSession(String clientId) |
addServiceListener, dispose, isStarted, isStopped, isStopping, postStop, preStart, removeServiceListener, start, stop
protected void doStop(ServiceStopper stopper) throws Exception
doStop
in class ServiceSupport
Exception
protected void doStart() throws Exception
doStart
in class ServiceSupport
Exception
public void startClientSession(String clientId)
public boolean stopClientSession(String clientId)
public short setPacketId(String clientId, MQTTSubscription subscription, ActiveMQMessage message, org.fusesource.mqtt.codec.PUBLISH publish)
public void ackPacketId(String clientId, short packetId)
public short getNextSequenceId(String clientId)
public static MQTTPacketIdGenerator getMQTTPacketIdGenerator(BrokerService broker)
Copyright © 2005–2019 The Apache Software Foundation. All rights reserved.