1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
| import Emitter from './Emitter'
| import Mqtt from 'mqtt'
|
| export default class {
|
| constructor(connection, options) {
| if (typeof connection === 'string') {
| this.Mqtt = Mqtt.connect(connection, options);
| } else {
| this.Mqtt = connection
| }
|
| this.Mqtt.on('message', (topic, payload, packet) => {
| Emitter.emit(topic, payload);
| });
| }
|
| }
|
|
