diff --git a/psq/psqworker.py b/psq/psqworker.py
index <HASH>..<HASH> 100755
--- a/psq/psqworker.py
+++ b/psq/psqworker.py
@@ -51,6 +51,8 @@ def import_queue(location):
     module, attr = location.rsplit('.', 1)
     module = import_module(module)
     queue = getattr(module, attr)
+    if hasattr(queue, '__call__'):
+        queue = queue()
     return queue
if queue is a function, call it to get the queue object (#7)