eclipse / paho.mqtt.javascript Goto Github PK

normal

$ mvn

src/tests

$ mvn test

// Create a client instance
var client = new Paho.MQTT.Client(location.hostname, Number(location.port), "clientId");

// set callback handlers
client.onConnectionLost = onConnectionLost;
client.onMessageArrived = onMessageArrived;

// connect the client
client.connect({onSuccess:onConnect});

// called when the client connects
function onConnect() {
  // Once a connection has been made, make a subscription and send a message.
  console.log("onConnect");
  client.subscribe("World");
  message = new Paho.MQTT.Message("Hello");
  message.destinationName = "World";
  client.send(message);
}

// called when the client loses its connection
function onConnectionLost(responseObject) {
  if (responseObject.errorCode !== 0) {
    console.log("onConnectionLost:"+responseObject.errorMessage);
  }
}

// called when a message arrives
function onMessageArrived(message) {
  console.log("onMessageArrived:"+message.payloadString);
}
 Mobile App publishes messages to back end

 App is deployed to field on laptop roaming in and out of wifi

a115bee
f0cd0c6
      if(arguments.length == 0){
          throw new Error("Invalid argument."+"length");

      }else if(arguments.length == 1) {

          if (!(topic instanceof Message) && (typeof topic !== "string"))
              throw new Error("Invalid argument:"+ typeof topic);

          message = topic;
          if (typeof message.destinationName === "undefined")
              throw new Error(format(ERROR.INVALID_ARGUMENT,[message.destinationName,"Message.destinationName"]));
          client.send(message); 

      }else {
          //parameter checking in Message object 
          message = new Message(payload);
          message.destinationName = topic;
          if(arguments.length >= 3)
              message.qos = qos;
          if(arguments.length >= 4)
              message.retained = retained;
          client.send(message); 
      }
  };

1ffbead
fcb3b0a
        var message = new Messaging.Message(input.subarray(pos));

        var message = new Messaging.Message(input.subarray(pos, endPos));
      if ((messageInfo & 0x01) == 0x01) 
          message.retained = true;
      if ((messageInfo & 0x08) == 0x08)

cda7202
 ClientImpl.prototype.store = function(prefix, wireMessage) {
        var storedMessage = {type:wireMessage.type,  messageIdentifier:wireMessage.messageIdentifier, version:1};

        switch(wireMessage.type) {
          case MESSAGE_TYPE.PUBLISH:
              if(wireMessage.pubRecReceived)
                  storedMessage.pubRecReceived = true;

              // Convert the payload to a hex string.
              storedMessage.payloadMessage = {};
              var hex = "";
              var messageBytes = wireMessage.payloadMessage.payloadBytes;
              for (var i=0; i<messageBytes.length; i++) {
                if (messageBytes[i] <= 0xF)

...

    Message.prototype = {
        get payloadString() { return this._getPayloadString(); },
        get payloadBytes() { return this._getPayloadBytes(); },
        ...

    v.prototype.store = function (E, D) {
        var A = {type: D.type, messageIdentifier: D.messageIdentifier, version: 1};
        switch (D.type) {
            case o.PUBLISH:
                if (D.pubRecReceived) {
                    A.pubRecReceived = true
                }
                A.payloadMessage = {};
                var C = "";
                var B = D.payloadMessage.payloadBytes;
                for (var z = 0; z < B.length; z++) {
                    if (B[z] <= 15) {

...

    a.prototype = {
        get payloadStringfunction() {
            return this._getPayloadString()
        }, get payloadBytesfunction() {
            return this._getPayloadBytes()
        }, get destinationNamefunction() {
        ...

var message = new Paho.MQTT.Message(1);
message.destinationName = 'topic';
message.qos = 1;
mqttClient.send(message);

4798ac2
    var client;
    var host = "iot.eclipse.org";
    var port = 1883;
    var clientId = "sample-id";
    var sentMsgs = 0;

    // This function creates a new Messaging client and initiates a connect request.
    function doConnect() {
        client = new Messaging.Client(server, port, clientId);
        client.onConnected = onConnected;            // Callback when connected
        client.onConnectionLost = onConnectionLost;  // Callback when lost connection
        client.disconnectedPublishing = true;        // Enable disconnected publishing
        client.disconnectedBufferSize = 100;         //  Buffer size : 100

        client.connect(
            {
                cleanSession : false, 
                onSuccess : onConnectSuccess, 
                onFailure : onFailedConnect, 
                keepAliveInterval: 30, 
                reconnect : true,         // Enable automatic reconnect
                reconnectInterval: 10     // Reconnect attempt interval : 10 seconds
            }
        );
    }

    // This function is called when the initial connect request is successful.
    function onConnectSuccess(resObj) {
        console.log("Initial connect request succeeded.");
    }

    // This function is called when the intial connect request failed.
    function onFailedConnect(err) {
        console.log("Initial connect request failed. Error message : " + err.errorMessage); 
    }

    // This function is called for all successful connection
    function onConnected(resObj) {
        console.log("Connected to " + resObj.uri);
        if (resObj.reconnect) {
            console.log("It was a result of automatic reconnect.");
        }
    }

    // This function is called when the connection is lost.
    function onConnectionLost(resObj) {
        console.log("Lost connection to " + resObj.uri + "\nError code: " + resObj.errorCode + "\nError text: " + resObj.errorMessage);
        if (resObj.reconnect) {
            console.log("Automatic reconnect is currently active.");
        } else {
            alert("Lost connection to host.");.
        }
    }

    function doSend() {
        // Starts timer to send a message every second
        publishTimer = setInterval(function () {sendTimer()}, 1000);
    }

    function sendTimer() {
        var message = new Messaging.Message("Test Message " + sentMsgs);
        message.destinationName = "/test/topic1";
        message.qos = 1;
        try {
            client.send(message);
            sentMsgs++;
            if (client.bufferedMessages > 0) {
                console.log("Buffered messages : " + client.bufferedMessages);
            }
        } catch (err) {
            console.log("Error occured after " + sentMsgs + " messages sent. Error : " + err.message);
        }
    }

eclipse / paho.mqtt.javascript Goto Github PK

paho.mqtt.javascript's Introduction

Eclipse Paho JavaScript client

Project description:

Links

Using the Paho Javascript Client

Downloading

Building from source

Tests

Documentation

Compatibility

Getting Started

Breaking Changes

paho.mqtt.javascript's People

Contributors

Stargazers

Watchers

Forkers

paho.mqtt.javascript's Issues

The trace in console:

this.socket = new WebSocket(wsurl, ["mqtt","mqttv3.1"]);

The stack trace only shows line numbers, the problem area is the SUBACK case in _handleMessage,

if (wireMessage.returnCode.indexOf(0x80) !== -1) {

Automatic Reconnect and Disconnected Publishing Plan

Recap: Possible Client States

What does it do?

Automatic Reconnect

Disconnected Publishing

API Changes

Automatic Reconnect

Disconnected Publishing

New Error

Sample application

Recommend Projects

Recommend Topics

Recommend Org