 
         distributeJobs = (queues...) =>
             _.each queues, (q) =>
-                @redis.lpop Q_PREFIX + q, (err, jobId) =>
+                @redis.lpop q, (err, jobId) =>
                     if jobId
                         if workers[q] and workers[q].length
                             worker = workers[q].pop()

                                pusher.send worker, "", q, jsonJob
                        else
                            # nobody's ready, back in the front of the line
                            @redis.lpush Q_PREFIX + q, jobId

        routes = {}
        route = (regEx, actions) ->


DEFAULT_PORT = 7000
DEFAULT_HOST = "localhost"

class Server extends process.EventEmitter

