Skip to content

Commit 2cb097e

Browse files
committed
paho: Bind self explicitly
1 parent 3c24f7a commit 2cb097e

1 file changed

Lines changed: 5 additions & 3 deletions

File tree

msgflo/msgflo.py

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -247,9 +247,11 @@ def __init__(self, broker):
247247
if self.broker_info.username:
248248
self._client.username_pw_set(self.broker_info.username, self.broker_info.password)
249249

250-
self._client.on_connect = self._on_connect
251-
self._client.on_message = self._on_message
252-
self._client.on_subscribe = self._on_subscribe
250+
#self._client.on_connect = _on_connect
251+
self._client.on_connect = lambda c, u, f, rc: self._on_connect(c, u, f, rc)
252+
self._client.on_message = lambda c, u, m: self._on_message(c, u, m)
253+
self._client.on_subscribe = lambda c, u, m, q: self._on_subscribe(c, u, m, q)
254+
253255
host = self.broker_info.hostname
254256
port = self.broker_info.port
255257
if port is None:

0 commit comments

Comments
 (0)