 (defn- cleanup-before [state txid]
   (.cleanupBefore state (to-txid txid)))
 
-
-
 (deftest test-rotating-transactional-state
   ;; test strict ordered vs not strict ordered
   (let [zk-port (available-port 2181)]

        (.close state)
        ))))

;; * Test that coordinator and partitioned state are cleaned up properly (and not too early) - test rotatingtransactionalstate


;;  should test that it commits even when receiving no tuples (and test that finishBatch is called before commit in this case)



(defn mk-coordinator-state-changer [atom]
  (TransactionalSpoutCoordinator.
