Added worker_queues() to celery.worker.control.builtins. It is a remote control command which retrieves the queues associated with a particular worker.

celery/task/control.py

@@ -70,6 +70,9 @@ class Inspect(object):
     def cancel_consumer(self, queue, **kwargs):
         return self._request("cancel_consumer", queue=queue, **kwargs)
 
+    def worker_queues(self):
+        return self._request("worker_queues")
+
 
 class Control(object):
     Mailbox = Mailbox

celery/worker/control/builtins.py

@@ -212,3 +212,9 @@ def cancel_consumer(panel, queue=None, **_):
     cset = panel.consumer.task_consumer
     cset.cancel_by_queue(queue)
     return {"ok": "no longer consuming from %s" % (queue, )}
+    
+@Panel.register
+def worker_queues(panel):
+    """Returns the queues associated with each worker."""
+    return dict(panel.consumer.queues.iteritems())
+