diff options
| author | Ivar Refsdal <ivar.refsdal@nsd.no> | 2021-09-14 21:01:16 +0200 |
|---|---|---|
| committer | Ivar Refsdal <ivar.refsdal@nsd.no> | 2021-09-14 21:01:16 +0200 |
| commit | 988c985666139f5246772c3e5e059c62627ea88b (patch) | |
| tree | 5da1775cb006ad162ec194663c6e6d4a4e66038a /src/com/github/ivarref/yoltq.clj | |
| parent | Release 0.1.5 (diff) | |
| download | fiinha-988c985666139f5246772c3e5e059c62627ea88b.tar.gz fiinha-988c985666139f5246772c3e5e059c62627ea88b.tar.xz | |
Only keep handlers from old config
Diffstat (limited to 'src/com/github/ivarref/yoltq.clj')
| -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" {}))) |