How to use mqtt

app.js

GitHub: vasinov/neural-lambda

151
152
153
154
155
156
157
158
          );
        }
      }
    });

    mqtt.disconnect();
  });
};

0

7

1

See more examples

README.md?plain=1

GitHub: yunba/MQTT.js

14
15
16
17
18
19
20
21
22
23
  details. A Connection is a Writable stream, so you can run
  MQTT.js over any kind of Stream (doc needed). Both the constructors of
  MqttClient and MqttConnection changed, but not the factory method
  `mqtt.createClient` and `mqtt.createConnection`.

* v0.2.0 has brough some API breaking changes to mqtt.js. 
  Please consult the [migration guide](http://github.com/adamvr/MQTT.js/wiki/migration) for information
  or open an issue if you need any help.

## Installation

0

7

11

See more examples

mqtt-client.js

GitHub: IntelEdisonDemoDay/iotkit-comm-js

46
47
48
49
50
51
52
53
54
55
    certPath: crypto.getUserSSLCert(),
    ca: calist
  };
  console.log("Connecting securely to MQTT broker at " + serviceSpec.properties.secureaddress + ":" +
    serviceSpec.properties.secureport);
  this.client = mqtt.createSecureClient(serviceSpec.properties.secureport, serviceSpec.properties.secureaddress,
    opts);
} else {
  this.client = mqtt.createClient(serviceSpec.port, serviceSpec.address);
}

10

0

13

See more examples

app.js

GitHub: vasinov/neural-lambda

135
136
137
138
139
140
141
142
143
144
var
  dataPoint = reading.values,
  outputTopic = config.mqtt.outputTopic + "/" + reading.device_id;

if (dataPoint.t > config.alarm.maxTemp || dataPoint.p > config.alarm.maxPressure) {
  mqtt.publish(
    outputTopic, { alarm: 1, values: dataPoint }
  );
} else {
  alarm.train(trainingData);

0

7

1

See more examples

index.js

GitHub: LI-NA/async-mqtt

-1

47

0

0

See more examples

mqtt-client.js

GitHub: IntelEdisonDemoDay/iotkit-comm-js

49
50
51
52
53
54
55
56
57
58
  console.log("Connecting securely to MQTT broker at " + serviceSpec.properties.secureaddress + ":" +
    serviceSpec.properties.secureport);
  this.client = mqtt.createSecureClient(serviceSpec.properties.secureport, serviceSpec.properties.secureaddress,
    opts);
} else {
  this.client = mqtt.createClient(serviceSpec.port, serviceSpec.address);
}

this.spec = serviceSpec;
this.client.subscribe(this.spec.name);

10

0

13

See more examples

streaming.js

GitHub: hjespers/teslams

130
131
132
133
134
135
136
137
138
139
if (!argv.topic) {
    console.log('No AWS IOT topic specified. Using teslams/{id} where {id} is the vehicle id of the car');
    argv.topic = 'teslams';
}
//
// Device is an instance returned by mqtt.Client(), see mqtt.js for full
// documentation.
//
device.on('connect', function() {
    ulog('awsiot device connected!');

112

418

58

See more examples

index.js

GitHub: goran-mahovlic/eez-flow-extensions

83
84
85
86
87
88
89
90
91
92
                ];
            }

async execute(runningFlow) {

        const client = await mqtt.connectAsync(this.url);
        console.log("Mqtt connect");

        await new Promise((resolve, reject) => {
            client.on('connect', function () {

0

1

2

See more examples

app.js

GitHub: maddox/harmony-api

25
26
27
28
29
30
31
32
33
34
var harmonyDeviceUpdateInterval = 1*60*1000 // 1 minute
var harmonyDeviceUpdateTimers = {}

var mqttClient = config.hasOwnProperty("mqtt_options") ?
    mqtt.connect(config.mqtt_host, config.mqtt_options) :
    mqtt.connect(config.mqtt_host);
var TOPIC_NAMESPACE = config.topic_namespace || "harmony-api";

var enableHTTPserver = config.hasOwnProperty("enableHTTPserver") ?
    config.enableHTTPserver : true;

118

387

48

See more examples