We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
2 parents e02f7b3 + a2fc882 commit c37da28Copy full SHA for c37da28
src/mqtt.coffee
@@ -105,7 +105,7 @@ class Client extends interfaces.MessagingClient
105
handlers = @subscribers[topic]
106
107
debug 'message', handlers.length, msg != null
108
- return if not msg or not handlers
+ return if not handlers
109
out =
110
data: msg
111
mqtt: message
src/routing.coffee
@@ -60,6 +60,7 @@ class Binder
60
binding = @bindings[id]
61
return callback new Error "Binding does not exist" if not binding
62
binding.enabled = false
63
+ delete @bindings[id]
64
#FIXME: add an unsubscribeQueue to Client/transport, and use that
65
return callback null
66
0 commit comments