 
            (.release semaphore)
 
-           (is (not= ::timed-out (deref cmd-1 5000 ::timed-out)))
-           (is (not= ::timed-out (deref cmd-2 5000 ::timed-out)))
-           (is (not= ::timed-out (deref cmd-3 5000 ::timed-out)))
+           (is (not= ::timed-out (deref cmd-1 tutils/default-timeout-ms ::timed-out)))
+           (is (not= ::timed-out (deref cmd-2 tutils/default-timeout-ms ::timed-out)))
+           (is (not= ::timed-out (deref cmd-3 tutils/default-timeout-ms ::timed-out)))
 
            ;; There's currently a lot of layering in the messaging
            ;; stack. The callback mechanism that delivers the promise


            (handle-message (store-command' q new-catalog-cmd))

            (is (= ::handled-first-message (deref fut (* 1000 60) nil)))
            (is (empty? (fs/list-dir (:path dlo))))
            (let [failed-cmdref (take-with-timeout!! command-chan default-timeout-ms)]
              (is (= 1 (count (:attempts failed-cmdref))))

            [puppetlabs.puppetdb.queue :as queue]
            [puppetlabs.trapperkeeper.services
             :refer [service-context]]
            [overtone.at-at :refer [mk-pool scheduled-jobs]]
            [puppetlabs.puppetdb.testutils :as tutils])
  (:import [java.util.concurrent TimeUnit]
           [org.joda.time DateTime DateTimeZone]))

