                                  :payload new-wire-catalog}]
 
             (handle-message (store-command' q new-catalog-cmd))
-            (reset! second-message? true)
 
             @fut
 

              (is (-> failed-cmdref :attempts first :exception
                      pg-serialization-failure-ex?)))

            (is (true? @first-message?))
            (is (true? @second-message?))))))))

(let [cases [{:certname "foo.example.com"
              :command {:command (command-names :deactivate-node)

                        (.countDown latch)
                        (apply orig-replace-existing-catalog args))]
          (let [first-message? (atom false)
                fut (future
                      (handle-message (store-command' q command))
                      (reset! first-message? true))
