Add function to get the set of active queue processors

(imported from commit 1b9e52cfaf00827305a8f790091860436739d11c)
This commit is contained in:
Zev Benjamin 2013-10-23 14:50:21 -04:00
parent 822edaa890
commit f241897c5b
1 changed files with 3 additions and 0 deletions

View File

@ -40,6 +40,9 @@ def register_worker(queue_name, clazz):
def get_worker(queue_name):
return worker_classes[queue_name]()
def get_active_worker_queues():
return worker_classes.iterkeys()
class QueueProcessingWorker(object):
def __init__(self):
self.q = SimpleQueueClient()