Skip to content

Commit 70ad76c

Browse files
committed
Removed notify from amqp example
1 parent 7197e33 commit 70ad76c

File tree

1 file changed

+0
-2
lines changed

1 file changed

+0
-2
lines changed

examples/amqp.py

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -55,15 +55,13 @@ def handle(self):
5555
while True:
5656
try:
5757
self._connection.drain_events()
58-
self.notify()
5958
except socket.timeout:
6059
log.debug("nothing to consume...")
6160
break
6261
self._connection.close()
6362

6463
def run(self):
6564
while self.alive:
66-
self.notify()
6765
try:
6866
self.handle()
6967
except Exception:

0 commit comments

Comments
 (0)