Now works with Celery 2.2

ask · Feb 23, 2011 · aa8c917 · aa8c917
1 parent 3db5e79
commit aa8c917
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/celerymonitor/bin/celerymond.py b/celerymonitor/bin/celerymond.py
@@ -62,7 +62,7 @@ def run(self, loglevel="ERROR", logfile=None, http_port=8989,
         print(STARTUP_INFO_FMT % {
                 "http_port": http_port,
                 "http_address": http_address or "localhost",
-                "conninfo": app.amqp.format_broker_info(),
+                "conninfo": app.broker_connection().as_uri(),
         })
 
         print("celerymon has started.")