| 1 | var mqtt = require('./');
|
| 2 | var client = mqtt.connect('mqtt://test.mosquitto.org');
|
| 3 |
|
| 4 | client.subscribe('presence');
|
| 5 | client.publish('presence', 'Hello mqtt');
|
| 6 |
|
| 7 | client.on('message', function (topic, message) {
|
| 8 | console.log(message.toString());
|
| 9 | });
|
| 10 |
|
| 11 | client.end();
|