                        .getNextException
                        .getMessage))))
 
-            @fut
             (is (true? @first-message?))
             (is (true? @second-message?))))))))
 

            (handle-message (store-command' q new-catalog-cmd))
            (reset! second-message? true)
            (is (empty? (fs/list-dir (:path dlo))))

            (let [failed-cmdref (take-with-timeout!! command-chan default-timeout-ms)]
              (is (= 1 (count (:attempts failed-cmdref))))

                      command-delay-ms 10000
                      scf-store/update-facts!
                      (fn [fact-data]
                        (.countDown latch)
                        (storage-replace-facts! fact-data))]
          (let [first-message? (atom false)
                second-message? (atom false)
                fut (future
                      (handle-message (store-command' q command))
                      (reset! first-message? true))

                new-facts (update-in facts [:values]
                                     (fn [values]
