schedule with fixed delay

rfresh2 · Nov 3, 2023 · 9fd8282 · 9fd8282
1 parent 27e13aa
commit 9fd8282
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/main/java/vc/live/LiveFeed.java b/src/main/java/vc/live/LiveFeed.java
@@ -64,7 +64,7 @@ public LiveFeed(final RedisClient redisClient,
         this.executorService = executorService;
         this.objectMapper = objectMapper;
         syncChannels();
-        this.executorService.scheduleAtFixedRate(this::processMessageQueue, ((int) (Math.random() * 10)), 10, SECONDS);
+        this.executorService.scheduleWithFixedDelay(this::processMessageQueue, ((int) (Math.random() * 10)), 10, SECONDS);
         inputQueues().forEach(this::monitorQueue);
     }
 
@@ -73,7 +73,7 @@ record InputQueue<T>(String queueName, Class<T> deserializedType, Function<T, Em
     private void monitorQueue(final InputQueue inputQueue) {
         final RBoundedBlockingQueue<String> queue = this.redisClient.getQueue(inputQueue.queueName());
         inputQueues.put(inputQueue, queue);
-        this.executorService.scheduleAtFixedRate(() -> processInputQueue(queue, inputQueue), 1, 3, SECONDS);
+        this.executorService.scheduleWithFixedDelay(() -> processInputQueue(queue, inputQueue), 1, 3, SECONDS);
     }
 
     private String feedName() {