gistfile1.clj

(defspout resque-spout ["action"]
  [conf context collector]
  (let [pool (redis/redis (:resque (config/redis-config)))]
   (spout
    (nextTuple []
     (when-let [string (get-action redis)]
       (when-let [action (action-from-resque string)]
         (let [id (str (java.util.UUID/randomUUID))]
           (emit-spout! collector [action] :id id)))))
    (ack [id]
         (log/info "finished processing action " id)
         (acknowledge-success! id))
    (fail [id]
          (log/info "failed to process action " id)
          (handle-failure! id)))))