WIP

diff --git a/src/main/java/de/juplo/kafka/chat/backend/persistence/inmemory/ShardedChatHome.java b/src/main/java/de/juplo/kafka/chat/backend/persistence/inmemory/ShardedChatHome.java
index ab3969f55b7adee91fa2c0aab976496a983a196b..b8bc4b8ec9d598e790dd594edf58498ad470b567 100644 (file)
--- a/src/main/java/de/juplo/kafka/chat/backend/persistence/inmemory/ShardedChatHome.java
+++ b/src/main/java/de/juplo/kafka/chat/backend/persistence/inmemory/ShardedChatHome.java
@@ -50,8 +50,11 @@ public class ShardedChatHome implements ChatHome
         : chatHomes[shard]
             .getChatRoom(id)
             .onErrorMap(throwable -> throwable instanceof UnknownChatroomException
-            ? Mono.error(new UnknownChatroomException(id, shard, ownedShards))
-            : Mono.error(throwable));
+            ? new UnknownChatroomException(
+                id,
+                shard,
+                ownedShards.stream().mapToInt(i -> i.intValue()).toArray())
+            : throwable);
   }
 
   @Override