       (ack [id]))))
 
 
-(defspout reaction-spout ["zid" "last-timestamp" "reaction"] {:prepare true}
+(defspout reaction-spout ["zid" "last-timestamp" "reactions"] {:prepare true}
   [conf context collector]
   (let [poll-interval   1000
         pg-spec         (poll/heroku-db-spec (env/env :database-url))

  (:gen-class))


(defspout sim-reaction-spout ["zid" "last-timestamp" "reaction"] {:prepare true}
  [conf context collector]
  (let [at-a-time 10
        interval 1000

            (emit-spout! collector [zid @last-timestamp rxns]))
          ; Update timestamp if needed
          (swap! last-timestamp
                 (fn [last-ts] (apply max 0 last-ts (map :created new-votes)))))
        (Thread/sleep poll-interval))
      (ack [id]))))


