data leaves spout, but doesn't arrive at bolt

topo_and_bolt.clj

(defbolt build-package-hash-bolt ["package"]
  [tuple collector]
  (emit-bolt! collector [(build-package-hash (:message tuple))] :anchor tuple)
  (ack! collector tuple))

(defbolt json-deser-bolt ["message"]
  [tuple collector]
  (try
    (emit-bolt! collector [(json/parse-string (:message tuple))] :anchor tuple)
    (ack! collector tuple)
    (catch Exception e (fail! collector tuple))))

(defn mk-redis-topology
  [keyspace_name host port timeout password]
  (topology
   {"node-input" (spout-spec (RedisPubSubSpout. host port queue timeout password))}

   {"json-deser" (bolt-spec {"node-input" :shuffle}
                            json-deser-bolt)

    "build-package-hash" (bolt-spec {"json-deser" :shuffle}
                                    build-package-hash-bolt)

    "write-package-to-db" (bolt-spec {"build-package-hash" :shuffle}
                                     (pkg/put-bolt keyspace_name))}))

Thread for gist is here: https://groups.google.com/d/topic/storm-user/Nc-mTd6cwB4/discussion