Skip to content
Browse files

Close consumer channel on disconnect

  • Loading branch information...
1 parent 355d986 commit d03f0e1e027bbdf67f489d4e7c2b1b63cd71e8f0 @oldpatricka oldpatricka committed Jan 15, 2013
Showing with 1 addition and 0 deletions.
  1. +1 −0 dashi/__init__.py
View
1 dashi/__init__.py
@@ -241,6 +241,7 @@ def connect(self):
def disconnect(self):
self._consumer.cancel()
+ self._channel.close()
self._conn.release()
def consume(self, count=None, timeout=None):

0 comments on commit d03f0e1

Please sign in to comment.
Something went wrong with that request. Please try again.