Package kr.ac.konkuk.ccslab.cm.entity

Class CMMqttSession

java.lang.Object
kr.ac.konkuk.ccslab.cm.entity.CMMqttSession
public class CMMqttSession extends Object
The CMMqttSession class represents a MQTT session.

  • Constructor Details

    • CMMqttSession

      public CMMqttSession()

  • Method Details

    • setMqttWill

      public void setMqttWill(CMMqttWill mqttWill)

    • getMqttWill

      public CMMqttWill getMqttWill()

    • setSubscriptionList

      public void setSubscriptionList(CMList<CMMqttTopicQoS> subscriptionList)

    • getSubscriptionList

      public CMList<CMMqttTopicQoS> getSubscriptionList()

    • setReqSubscriptionList

      public void setReqSubscriptionList(CMList<CMMqttTopicQoS> reqSubscriptionList)

    • getReqSubscriptionList

      public CMList<CMMqttTopicQoS> getReqSubscriptionList()

    • setSentUnAckPublishList

      public void setSentUnAckPublishList(CMList<CMMqttEventPUBLISH> pubList)

    • getSentUnAckPublishList

      public CMList<CMMqttEventPUBLISH> getSentUnAckPublishList()

    • setRecvUnAckPublishList

      public void setRecvUnAckPublishList(CMList<CMMqttEventPUBLISH> pubList)

    • getRecvUnAckPublishList

      public CMList<CMMqttEventPUBLISH> getRecvUnAckPublishList()

    • setRecvUnAckPubrecList

      public void setRecvUnAckPubrecList(CMList<CMMqttEventPUBREC> recList)

    • getRecvUnAckPubrecList

      public CMList<CMMqttEventPUBREC> getRecvUnAckPubrecList()

    • setPendingTransPublishList

      public void setPendingTransPublishList(CMList<CMMqttEventPUBLISH> eventList)

    • getPendingTransPublishList

      public CMList<CMMqttEventPUBLISH> getPendingTransPublishList()

    • getNextAssignedPacketID

      public int getNextAssignedPacketID(int nEventID)

    • setSentUnAckSubList

      public void setSentUnAckSubList(CMList<CMMqttEventSUBSCRIBE> eventList)

    • getSentUnAckSubList

      public CMList<CMMqttEventSUBSCRIBE> getSentUnAckSubList()

    • setSentUnAckUnsubList

      public void setSentUnAckUnsubList(CMList<CMMqttEventUNSUBSCRIBE> eventList)

    • getSentUnAckUnsubList

      public CMList<CMMqttEventUNSUBSCRIBE> getSentUnAckUnsubList()

    • addSubscription

      public boolean addSubscription(CMMqttTopicQoS topicQoS)

    • findSubscription

      public CMMqttTopicQoS findSubscription(String strTopic)

    • removeSubscription

      public boolean removeSubscription(String strTopic)

    • removeAllSubscription

      public void removeAllSubscription()

    • addSentUnAckPublish

      public boolean addSentUnAckPublish(CMMqttEventPUBLISH pubEvent)

    • findSentUnAckPublish

      public CMMqttEventPUBLISH findSentUnAckPublish(int nPacketID)

    • removeSentUnAckPublish

      public boolean removeSentUnAckPublish(int nPacketID)

    • removeAllSentUnAckPublish

      public void removeAllSentUnAckPublish()

    • addRecvUnAckPublish

      public boolean addRecvUnAckPublish(CMMqttEventPUBLISH pubEvent)

    • findRecvUnAckPublish

      public CMMqttEventPUBLISH findRecvUnAckPublish(int nPacketID)

    • removeRecvUnAckPublish

      public boolean removeRecvUnAckPublish(int nPacketID)

    • removeAllRecvUnAckPublish

      public void removeAllRecvUnAckPublish()

    • addRecvUnAckPubrec

      public boolean addRecvUnAckPubrec(CMMqttEventPUBREC recEvent)

    • findRecvUnAckPubrec

      public CMMqttEventPUBREC findRecvUnAckPubrec(int nPacketID)

    • removeRecvUnAckPubrec

      public boolean removeRecvUnAckPubrec(int nPacketID)

    • removeAllRecvUnAckPubrec

      public void removeAllRecvUnAckPubrec()

    • addPendingTransPublish

      public boolean addPendingTransPublish(CMMqttEventPUBLISH pubEvent)

    • findPendingTransPublish

      public CMMqttEventPUBLISH findPendingTransPublish(int nPacketID)

    • removePendingTransPublish

      public boolean removePendingTransPublish(int nPacketID)

    • removeAllPendingTransPublish

      public void removeAllPendingTransPublish()

    • addSentUnAckSubscribe

      public boolean addSentUnAckSubscribe(CMMqttEventSUBSCRIBE subEvent)

    • findSentUnAckSubscribe

      public CMMqttEventSUBSCRIBE findSentUnAckSubscribe(int nPacketID)

    • removeSentUnAckSubscribe

      public boolean removeSentUnAckSubscribe(int nPacketID)

    • removeAllSentUnAckSubscribe

      public void removeAllSentUnAckSubscribe()

    • addSentUnAckUnsubscribe

      public boolean addSentUnAckUnsubscribe(CMMqttEventUNSUBSCRIBE unsubEvent)

    • findSentUnAckUnsubscribe

      public CMMqttEventUNSUBSCRIBE findSentUnAckUnsubscribe(int nPacketID)

    • removeSentUnAckUnsubscribe

      public boolean removeSentUnAckUnsubscribe(int nPacketID)

    • removeAllSentUnAckUnsubscribe

      public void removeAllSentUnAckUnsubscribe()

    • toString

      public String toString()
      Overrides:
      toString in class Object