diff options
| -rw-r--r-- | src/com/github/ivarref/yoltq.clj | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/src/com/github/ivarref/yoltq.clj b/src/com/github/ivarref/yoltq.clj index 2eb39e8..d04462f 100644 --- a/src/com/github/ivarref/yoltq.clj +++ b/src/com/github/ivarref/yoltq.clj @@ -75,11 +75,11 @@ (fn [old-conf] (-> (merge-with (fn [a b] (or b a)) {:running-queues (atom #{}) - :start-execute-time (atom {})} + :start-execute-time (atom {}) + :system-error (atom {})} default-opts - old-conf + (select-keys old-conf [:handlers]) cfg) - (assoc :system-error (atom {})) u/duration->nanos)))] new-cfg))) @@ -160,9 +160,9 @@ (let [ok-items (atom []) conn (d/connect uri) n 100] - (init! {:conn conn - :error-backoff-time (Duration/ofSeconds 1) - :poll-delay (Duration/ofSeconds 1)}) + (init! {:conn conn + :error-backoff-time (Duration/ofSeconds 1) + :poll-delay (Duration/ofSeconds 1)}) (add-consumer! :q (fn [payload] (when (> (Math/random) 0.5) (throw (ex-info "oops" {}))) |