Package com.swiftmq.impl.mqtt.session

Class MQTTSession

java.lang.Object

com.swiftmq.impl.mqtt.po.MQTTVisitorAdapter

com.swiftmq.impl.mqtt.session.MQTTSession

All Implemented Interfaces:

MQTTVisitor

public class MQTTSession
extends MQTTVisitorAdapter

Constructor Summary

Constructors

Constructor	Description
MQTTSession(SwiftletContext ctx, String clientId, boolean persistent)
MQTTSession(SwiftletContext ctx, String clientId, SessionStoreEntry sessionStoreEntry)

Method Summary

Modifier and Type	Method	Description
void	associate(MQTTConnection mqttConnection)
void	destroy()
void	destroy(boolean removeUsage)
void	destroy(ActiveLogin activeLogin, boolean removeUsage)
void	fillConnectionUsage(Entity connectionUsage)
void	fillRegistryUsage(Entity registryUsage)
String	getClientId()
long	getLastUse()
MQTTConnection	getMqttConnection()
int	getMsgsReceived()
int	getMsgsSent()
SessionStoreEntry	getSessionStoreEntry()
int	getTotalMsgsReceived()
int	getTotalMsgsSent()
boolean	isAssociated()
boolean	isPersistent()
boolean	isWasPresent()
int	nextDurableId()
void	setWasPresent(boolean wasPresent)
void	start()
void	stop()
String	topicNameTranslate(String mqttTopicName)
String	toString()
void	unsubscribe(String topicFilter, ActiveLogin activeLogin)
void	visit(POCollect po)
void	visit(POPubAck po)
void	visit(POPubComp po)
void	visit(POPublish po)
void	visit(POPubRec po)
void	visit(POPubRel po)
void	visit(POSendMessage po)
void	visit(POSubscribe po)
void	visit(POUnsubscribe po)

Methods inherited from class com.swiftmq.impl.mqtt.po.MQTTVisitorAdapter

visit, visit, visit, visit, visit, visit

Methods inherited from class java.lang.Object

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

Constructor Details

MQTTSession

public MQTTSession(SwiftletContext ctx,
 String clientId,
 boolean persistent)

MQTTSession

public MQTTSession(SwiftletContext ctx,
 String clientId,
 SessionStoreEntry sessionStoreEntry)
            throws Exception

Throws:

Exception

Method Details

isPersistent

public boolean isPersistent()

getClientId

public String getClientId()

getLastUse

public long getLastUse()

isWasPresent

public boolean isWasPresent()

setWasPresent

public void setWasPresent(boolean wasPresent)

associate

public void associate(MQTTConnection mqttConnection)

isAssociated

public boolean isAssociated()

getMqttConnection

public MQTTConnection getMqttConnection()

getMsgsReceived

public int getMsgsReceived()

getMsgsSent

public int getMsgsSent()

getTotalMsgsReceived

public int getTotalMsgsReceived()

getTotalMsgsSent

public int getTotalMsgsSent()

fillRegistryUsage

public void fillRegistryUsage(Entity registryUsage)

fillConnectionUsage

public void fillConnectionUsage(Entity connectionUsage)

getSessionStoreEntry

public SessionStoreEntry getSessionStoreEntry()

nextDurableId

public int nextDurableId()

topicNameTranslate

public String topicNameTranslate(String mqttTopicName)
                          throws Exception

Throws:

Exception

unsubscribe

public void unsubscribe(String topicFilter,
 ActiveLogin activeLogin)
                 throws Exception

Throws:

Exception

start

public void start()

stop

public void stop()

destroy

public void destroy()

destroy

public void destroy(ActiveLogin activeLogin,
 boolean removeUsage)

destroy

public void destroy(boolean removeUsage)

visit

public void visit(POPublish po)

Specified by:

visit in interface MQTTVisitor

Overrides:

visit in class MQTTVisitorAdapter

visit

public void visit(POSendMessage po)

Specified by:

visit in interface MQTTVisitor

Overrides:

visit in class MQTTVisitorAdapter

visit

public void visit(POPubAck po)

Specified by:

visit in interface MQTTVisitor

Overrides:

visit in class MQTTVisitorAdapter

visit

public void visit(POPubRec po)

Specified by:

visit in interface MQTTVisitor

Overrides:

visit in class MQTTVisitorAdapter

visit

public void visit(POPubRel po)

Specified by:

visit in interface MQTTVisitor

Overrides:

visit in class MQTTVisitorAdapter

visit

public void visit(POPubComp po)

Specified by:

visit in interface MQTTVisitor

Overrides:

visit in class MQTTVisitorAdapter

visit

public void visit(POSubscribe po)

Specified by:

visit in interface MQTTVisitor

Overrides:

visit in class MQTTVisitorAdapter

visit

public void visit(POUnsubscribe po)

Specified by:

visit in interface MQTTVisitor

Overrides:

visit in class MQTTVisitorAdapter

visit

public void visit(POCollect po)

Specified by:

visit in interface MQTTVisitor

Overrides:

visit in class MQTTVisitorAdapter

toString

public String toString()

Overrides:

toString in class Object