Przeglądaj źródła

Fixed camqadm to work with Kombu

Ask Solem 14 lat temu
rodzic
commit
ac778d5944
1 zmienionych plików z 1 dodań i 1 usunięć
  1. 1 1
      celery/bin/camqadm.py

+ 1 - 1
celery/bin/camqadm.py

@@ -318,7 +318,7 @@ class AMQShell(cmd.Cmd):
     def _reconnect(self):
         """Re-establish connection to the AMQP server."""
         self.conn = self.connect(self.conn)
-        self.chan = self.conn.create_backend().channel
+        self.chan = self.conn.channel()
         self.needs_reconnect = False
 
     @property