diff --git a/zerver/management/commands/process_queue.py b/zerver/management/commands/process_queue.py
index 32b37a148a..8bcdb82a7b 100644
--- a/zerver/management/commands/process_queue.py
+++ b/zerver/management/commands/process_queue.py
@@ -38,6 +38,7 @@ class Command(BaseCommand):
 
             logger.info("Worker %d connecting to queue %s" % (worker_num, queue_name))
             worker = get_worker(queue_name)
+            worker.setup()
 
             def signal_handler(signal, frame):
                 logger.info("Worker %d disconnecting from queue %s" % (worker_num, queue_name))