Skip to content

Commit 05cb926

Browse files
committed
mqtt: Debug on error/reconnect/offline
1 parent 358d1a4 commit 05cb926

File tree

1 file changed

+9
-0
lines changed

1 file changed

+9
-0
lines changed

src/mqtt.coffee

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,12 @@ class Client extends interfaces.MessagingClient
1919
return callback mqtt
2020

2121
@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'
2228
onConnected = (err) =>
2329
debug 'connected'
2430
@client.on 'message', (topic, message) =>
@@ -29,6 +35,9 @@ class Client extends interfaces.MessagingClient
2935
disconnect: (callback) ->
3036
@client.removeAllListeners 'message'
3137
@client.removeAllListeners 'connect'
38+
@client.removeAllListeners 'reconnect'
39+
@client.removeAllListeners 'offline'
40+
@client.removeAllListeners 'error'
3241
@subscribers = {}
3342
@client.end (err) =>
3443
debug 'disconnected'

0 commit comments

Comments
 (0)