         last-timestamp  (atom 0)]
     (spout
       (nextTuple []
-        (Thread/sleep poll-interval)
         (log/info "Polling :created >" @last-timestamp)
         (let [new-votes (poll/poll pg-spec @last-timestamp)
               grouped-votes (group-by :zid new-votes)]

      (ack [id]))))


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

            (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]))))


