We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 358d1a4 commit 05cb926Copy full SHA for 05cb926
1 file changed
src/mqtt.coffee
@@ -19,6 +19,12 @@ class Client extends interfaces.MessagingClient
19
return callback mqtt
20
21
@client = mqtt.connect @address
22
+ @client.on 'error', (err) =>
23
+ debug 'error', err
24
+ @client.on 'reconnect', () =>
25
+ debug 'reconnect'
26
+ @client.on 'offline', () =>
27
+ debug 'offline'
28
onConnected = (err) =>
29
debug 'connected'
30
@client.on 'message', (topic, message) =>
@@ -29,6 +35,9 @@ class Client extends interfaces.MessagingClient
35
disconnect: (callback) ->
36
@client.removeAllListeners 'message'
31
37
@client.removeAllListeners 'connect'
38
+ @client.removeAllListeners 'reconnect'
39
+ @client.removeAllListeners 'offline'
40
+ @client.removeAllListeners 'error'
32
41
@subscribers = {}
33
42
@client.end (err) =>
34
43
debug 'disconnected'
0 commit comments