                     }
 
             POST: (match, response, bag) ->
-                queue = match[1]
+                queue = Q_PREFIX + match[1]
                 id = uuid.generate()
                 job = JSON.stringify {
                     uuid: id,
                     message: bag
                 }
 
-                redisC.lpush queue, job, (err, status) ->
-                    respond response, { success: status, uuid: id }
-                    # Actually send this task out to be worked on
-                    pusher.send job
+                redisC.transaction ->
+                    redisC.set id, job
+                    redisC.lpush queue, id, (err, status) ->
+                        respond response, { success: status, uuid: id }
 
             DELETE: (match, response) ->
-                queue = match[1]
+                queue = Q_PREFIX + match[1]
                 redisC.del queue, (err, status) ->
                     respond response, {
                         success: status,


        addRoute "\/queue\/(.+?)\/?$", {
            GET: (match, response) ->
                queue = match[1]
                redisC.lrange queue, 0, -1, (err, messages) ->
                    respond response, {
                        success: true,


        addRoute "\/job\/(.+?)\/?$", {
            GET: (match, response) ->
                redisC.get match[1], (err, job) ->
                    respond response, job
        }

        listener = http.createServer (request, response) ->
