X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fchat%2Fbackend%2Fimplementation%2Fkafka%2FInfoChannel.java;h=3429d405245652e81ba5ab4e6fa03b7d31882c57;hb=74501b5661b0a760cf2b45aa055120b0d20ef2e2;hp=cf4d03c280225405aafe47ff1fd2b023454a6c76;hpb=a12ced5d2e733b957b106e8393f115941d983823;p=demos%2Fkafka%2Fchat 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)