                     @redis.set id, job
                     @redis.rpush queue, id, (err, status) ->
                         respond response, { success: status, uuid: id }
-                        distributeJobs(match[1])
+                        distributeJobs(queue)
 
             DELETE: (match, response) =>
-                queue = Q_PREFIX + match[1]
+                queue = match[1]
                 @redis.del queue, (err, status) ->
                     respond response, {
                         success: status,


DEFAULT_PORT = 7000
DEFAULT_HOST = "localhost"

Q_PREFIX = '__q'

class Server extends process.EventEmitter


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

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