From 74501b5661b0a760cf2b45aa055120b0d20ef2e2 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Sat, 3 Feb 2024 15:13:09 +0100 Subject: [PATCH] refactor: Renamed method in `InfoChannel` according to conventions --- .../chat/backend/implementation/kafka/ConsumerTaskRunner.java | 2 +- .../kafka/chat/backend/implementation/kafka/InfoChannel.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/ConsumerTaskRunner.java b/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/ConsumerTaskRunner.java index 983ebd37..c2c28014 100644 --- a/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/ConsumerTaskRunner.java +++ b/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/ConsumerTaskRunner.java @@ -21,7 +21,7 @@ public class ConsumerTaskRunner public void joinConsumerTasks() throws InterruptedException { dataChannelConsumerTaskExecutor.joinConsumerTaskJob(); - while (infoChannel.loadInProgress()) + while (infoChannel.isLoadInProgress()) { log.info("Waiting for {} to finish loading...", infoChannel); Thread.sleep(1000); diff --git a/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/InfoChannel.java b/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/InfoChannel.java index cf4d03c2..3429d405 100644 --- a/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/InfoChannel.java +++ b/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/InfoChannel.java @@ -68,7 +68,7 @@ public class InfoChannel implements Runnable } - boolean loadInProgress() + boolean isLoadInProgress() { return IntStream .range(0, numShards) -- 2.20.1