      (RegisteredGlobalState/clearState id#)
     ))
 
-;; cluster-map topology :mock-sources {} :storm-conf {}
+
 (deftest test-transactional-topology
   (with-tracked-cluster [cluster]
     (with-controller-bolt [controller collector tuples]

        (.close state)
        ))))



;; * Test that commit isn't considered successful until the entire tree has been completed (including tuples emitted from commit method)
;;      - test the full topology (this is a test of acking/anchoring)
;; * Test that batch isn't considered processed until the entire tuple tree has been completed
;;      - test the full topology (this is a test of acking/anchoring)
;; * Test that it picks up where it left off when restarting the topology
;;      - run topology and restart it


(defn mk-transactional-source []
  (HashMap.))


                         (doseq [t to-ack]
                           (.ack @collector t)))))

       (bind fail-tx! (fn [txid]
                        (let [[to-fail not-to-fail] (separate
                                                     #(-> %
                                                          (.getValue 0)
                                                          .getTransactionId
                                                          (= txid))
                                                     @tuples)]
                          (reset! tuples not-to-fail)
                          (doseq [t to-fail]
                            (.fail @collector t)))))

       ;; only check default streams
       (bind verify! (fn [expected]
                       (let [results (-> topo-info :capturer .getResults)]
