diff options
| author | Ivar Refsdal <refsdal.ivar@gmail.com> | 2022-03-28 20:34:13 +0200 |
|---|---|---|
| committer | Ivar Refsdal <refsdal.ivar@gmail.com> | 2022-03-28 20:34:13 +0200 |
| commit | e73fd80b689d4d5cdc803fe92775bb9551a44df4 (patch) | |
| tree | ec8765a258b6e44dd670512b48a27725be4c6dbf /src/com/github/ivarref/yoltq.clj | |
| parent | Document (diff) | |
| download | fiinha-e73fd80b689d4d5cdc803fe92775bb9551a44df4.tar.gz fiinha-e73fd80b689d4d5cdc803fe92775bb9551a44df4.tar.xz | |
Another bugfix: schedules should be using milliseconds and not nanoseconds.
Diffstat (limited to 'src/com/github/ivarref/yoltq.clj')
| -rw-r--r-- | src/com/github/ivarref/yoltq.clj | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/com/github/ivarref/yoltq.clj b/src/com/github/ivarref/yoltq.clj index e1fd1b0..7d5434e 100644 --- a/src/com/github/ivarref/yoltq.clj +++ b/src/com/github/ivarref/yoltq.clj @@ -116,8 +116,8 @@ (let [pool @threadpool queue-listener-ready (promise)] (reset! *running?* true) - (.scheduleAtFixedRate pool (fn [] (poller/poll-all-queues! *running?* *config* pool)) 0 poll-delay TimeUnit/NANOSECONDS) - (.scheduleAtFixedRate pool (fn [] (errpoller/poll-errors *running?* *config*)) 0 system-error-poll-delay TimeUnit/NANOSECONDS) + (.scheduleAtFixedRate pool (fn [] (poller/poll-all-queues! *running?* *config* pool)) 0 poll-delay TimeUnit/MILLISECONDS) + (.scheduleAtFixedRate pool (fn [] (errpoller/poll-errors *running?* *config*)) 0 system-error-poll-delay TimeUnit/MILLISECONDS) (.execute pool (fn [] (rq/report-queue-listener *running?* queue-listener-ready pool *config*))) (.execute pool (fn [] (slow-executor/show-slow-threads *running?* *config*))) @queue-listener-ready))) |