WIP

diff --git a/src/main/java/de/juplo/kafka/chat/backend/domain/LoadInProgressException.java b/src/main/java/de/juplo/kafka/chat/backend/domain/LoadInProgressException.java
index 4592502625a091a1dc4ea0c9de41cf629176b730..d87e76d323bf7ad55351618be9df217628fb946a 100644 (file)
--- a/src/main/java/de/juplo/kafka/chat/backend/domain/LoadInProgressException.java
+++ b/src/main/java/de/juplo/kafka/chat/backend/domain/LoadInProgressException.java
@@ -1,15 +1,10 @@
 package de.juplo.kafka.chat.backend.domain;
 
 
-import java.util.concurrent.atomic.AtomicInteger;
-
-
 public class LoadInProgressException extends IllegalStateException
 {
-  static AtomicInteger counter = new AtomicInteger();
-
   public LoadInProgressException()
   {
-    super("Load in progress... " + counter.incrementAndGet());
+    super("Load in progress...");
   }
 }

diff --git a/src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/ChatRoomChannel.java b/src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/ChatRoomChannel.java
index ad9531cb0cdf39ede09cc1a1a04293d6febd2779..234554ebbdd267ae1adefbc90d95190b7c99b767 100644 (file)
--- a/src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/ChatRoomChannel.java
+++ b/src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/ChatRoomChannel.java
@@ -369,13 +369,11 @@ public class ChatRoomChannel implements Runnable, ConsumerRebalanceListener
   {
     if (loadInProgress)
     {
-      log.error("Load in progress!");
       return Mono.error(new LoadInProgressException());
     }
 
     if (!isShardOwned[shard])
     {
-      log.error("Shard {} for chat-room {} not owned!", shard, id);
       return Mono.error(new ShardNotOwnedException(shard));
     }
 

diff --git a/src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/KafkaChatHome.java b/src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/KafkaChatHome.java
index 2788343f7b607c63f653ffe403917c7fc449be6a..07fb8858744f7853382db7a4c2cccfe42e1def54 100644 (file)
--- a/src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/KafkaChatHome.java
+++ b/src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/KafkaChatHome.java
@@ -26,13 +26,10 @@ public class KafkaChatHome implements ChatHome
     int shard = selectShard(id);
     return chatRoomChannel
         .getChatRoom(shard, id)
-        .switchIfEmpty(Mono.error(() -> {
-          log.error("Unknown chat-room {} (shard={})!", id, shard);
-          return new UnknownChatroomException(
-              id,
-              shard,
-              chatRoomChannel.getOwnedShards());
-        }));
+        .switchIfEmpty(Mono.error(() -> new UnknownChatroomException(
+            id,
+            shard,
+            chatRoomChannel.getOwnedShards())));
   }
 
   int selectShard(UUID chatRoomId)

diff --git a/src/test/resources/application.yml b/src/test/resources/application.yml
index 856b2e2441c33fc01dc461ca0915db857fc2fab8..96b0cb3b0f319e2432c2b8b780a6f8ab0d66400b 100644 (file)
--- a/src/test/resources/application.yml
+++ b/src/test/resources/application.yml
@@ -1,4 +1,4 @@
 logging:
   level:
     root: INFO
-    de.juplo.kafka.chat.backend: TRACE
+    de.juplo.kafka.chat.backend: DEBUG