Package com.simplicite.util.tools

Class MQTTTool

  • public class MQTTTool
extends java.lang.Object
    MQTTTool toolbox

    • Constructor Summary

      Constructors 
      Constructor Description
      MQTTTool​(Grant g, java.lang.String url)
      Constructor

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void connect()
      Connect to server
      void disconnect()
      Disconnect from server
      Grant getGrant()
      Get grant
      java.lang.String getURL()
      Get URL
      void publish​(java.lang.String topic, java.lang.Object payload)
      Publish to topic
      void subscribe​(java.lang.String topic)
      Subscribe to topic

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • MQTTTool

        public MQTTTool​(Grant g,
                java.lang.String url)
        Constructor
        Parameters:
        url - MQTT server URL

    • Method Detail

      • getGrant

        public Grant getGrant()
        Get grant

      • getURL

        public java.lang.String getURL()
        Get URL

      • connect

        public void connect()
             throws java.lang.Exception
        Connect to server
        Throws:
        java.lang.Exception

      • publish

        public void publish​(java.lang.String topic,
                    java.lang.Object payload)
             throws java.lang.Exception
        Publish to topic
        Parameters:
        topic - Topic
        payload - Payload
        Throws:
        java.lang.Exception

      • subscribe

        public void subscribe​(java.lang.String topic)
               throws java.lang.Exception
        Subscribe to topic
        Parameters:
        topic - Topic
        Throws:
        java.lang.Exception

      • disconnect

        public void disconnect()
                throws java.lang.Exception
        Disconnect from server
        Throws:
        java.lang.Exception