Requires pika >= 0.9.12.

pingviini · Apr 4, 2013 · 47c34d0 · 47c34d0
1 parent 0a08c1f
commit 47c34d0
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 3 deletions.
diff --git a/setup.py b/setup.py
@@ -26,7 +26,7 @@
       zip_safe=False,
       install_requires=[
           "setuptools",
-          "pika>=0.9.8",
+          "pika>=0.9.12",
       ],
       extras_require={
           'develop': ['Sphinx'],

diff --git a/src/pikacon/pikacon.py b/src/pikacon/pikacon.py
@@ -157,6 +157,7 @@ def loop(self):
                             self.reconnection_delay)
                 time.sleep(self.reconnection_delay)
 
-    def on_channel_closed(self, code, text):
-        logger.warning("Channel closed with reason '%s %s'", code, text)
+    def on_channel_closed(self, channel, code, text):
+        logger.warning("Channel %i closed with reason '%s %s'",
+                       channel, code, text)
         self.connection.close(code, text)