From fca62f261ee9f75248c90fc7609972ca4dde3116 Mon Sep 17 00:00:00 2001 From: Viktor Lofgren Date: Tue, 22 Aug 2023 11:49:30 +0200 Subject: [PATCH] (mq) Down-tune polling intervals in MQ Polling 10 times a second across dozens of queues is a bit too aggressive and wasteful. --- .../main/java/nu/marginalia/mq/inbox/MqAsynchronousInbox.java | 2 +- .../main/java/nu/marginalia/mq/inbox/MqSynchronousInbox.java | 2 +- .../src/main/java/nu/marginalia/mq/outbox/MqOutbox.java | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/code/libraries/message-queue/src/main/java/nu/marginalia/mq/inbox/MqAsynchronousInbox.java b/code/libraries/message-queue/src/main/java/nu/marginalia/mq/inbox/MqAsynchronousInbox.java index 94fa82f6..1eb45e6e 100644 --- a/code/libraries/message-queue/src/main/java/nu/marginalia/mq/inbox/MqAsynchronousInbox.java +++ b/code/libraries/message-queue/src/main/java/nu/marginalia/mq/inbox/MqAsynchronousInbox.java @@ -27,7 +27,7 @@ public class MqAsynchronousInbox implements MqInboxIf { private volatile boolean run = true; - private final int pollIntervalMs = Integer.getInteger("mq.inbox.poll-interval-ms", 100); + private final int pollIntervalMs = Integer.getInteger("mq.inbox.poll-interval-ms", 1000); private final int maxPollCount = Integer.getInteger("mq.inbox.max-poll-count", 10); private final List eventSubscribers = new ArrayList<>(); private final LinkedBlockingQueue queue = new LinkedBlockingQueue<>(32); diff --git a/code/libraries/message-queue/src/main/java/nu/marginalia/mq/inbox/MqSynchronousInbox.java b/code/libraries/message-queue/src/main/java/nu/marginalia/mq/inbox/MqSynchronousInbox.java index 09749209..f698b882 100644 --- a/code/libraries/message-queue/src/main/java/nu/marginalia/mq/inbox/MqSynchronousInbox.java +++ b/code/libraries/message-queue/src/main/java/nu/marginalia/mq/inbox/MqSynchronousInbox.java @@ -24,7 +24,7 @@ public class MqSynchronousInbox implements MqInboxIf { private volatile boolean run = true; - private final int pollIntervalMs = Integer.getInteger("mq.inbox.poll-interval-ms", 100); + private final int pollIntervalMs = Integer.getInteger("mq.inbox.poll-interval-ms", 1000); private final List eventSubscribers = new ArrayList<>(); private Thread pollDbThread; diff --git a/code/libraries/message-queue/src/main/java/nu/marginalia/mq/outbox/MqOutbox.java b/code/libraries/message-queue/src/main/java/nu/marginalia/mq/outbox/MqOutbox.java index 40022c11..61e73bec 100644 --- a/code/libraries/message-queue/src/main/java/nu/marginalia/mq/outbox/MqOutbox.java +++ b/code/libraries/message-queue/src/main/java/nu/marginalia/mq/outbox/MqOutbox.java @@ -22,7 +22,7 @@ public class MqOutbox { private final ConcurrentHashMap pendingResponses = new ConcurrentHashMap<>(); - private final int pollIntervalMs = Integer.getInteger("mq.outbox.poll-interval-ms", 100); + private final int pollIntervalMs = Integer.getInteger("mq.outbox.poll-interval-ms", 1000); private final int maxPollCount = Integer.getInteger("mq.outbox.max-poll-count", 10); private final Thread pollThread;