gistfile1.clj

(defbolt active-user-bolt ["id" "user-ids" "story"] {:prepare true}
  [conf context collector]
  (let [redii (redis/redii)]
    (bolt
     (execute [{id "id" story "story" :as tuple}]
              (doseq [user-id (active-users redii)]
                (emit-bolt! collector [id user-id story] :anchor tuple))
              (ack! collector tuple)))))