strongloop/strong-pubsub-mqtt

strong-pubsub-mqtt

An MQTT Adapter for strong-pubsub

Installation

$ npm install strong-pubsub-mqtt

Use

var Client = require('strong-pubsub');
var Adapter = require('strong-pubsub-mqtt');

var client = new Client({host: 'http://my.message-broker.com', port: 3000}, Adapter);

client.publish('my topic', 'my message');

strong-pubsub-mqtt's Issues

firstConnection.close is not a function

Hey,

Trying to manage connection time out, I've set connectionTimeout to 15000 in my config file.

But, in my case, firstConnection is a net.Socket => the close() function does not exist.

Everything goes fine when I use destroy() instead of close().

Do you want me to fork then create a pull request ? or you'll update that by yourself ?

Regards

use broker with authentication

Hi,

we would like to use loopback mqtt library with authentication like this:

var Client = require('strong-pubsub');
var Adapter = require('strong-pubsub-mqtt');
var client = new Client({host: localhost, port: 1883, username: 'xxxx', password: 'xxxx'}, Adapter);

but it didn't work, how can do this?

Bad dependency on unreleased version of pubsub-test

Failing on CI as a result.

Lost connection with message broker

When the connection is lost, there is no notification of this. And then the sending of messages will not work even if the connection with the broker is restored.