X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fchat%2Fbackend%2Fdomain%2FShardNotOwnedException.java;h=3b6383316f301e67fc1ee00c6492a27b92242f7c;hb=394aa7848abcfc7b4510cd2688c00fce01b3c225;hp=d467eabb0c4bd173e792473d41963c766e755fb6;hpb=dfe4f4f9b979b080ccb7c29af78a1c108c3040f4;p=demos%2Fkafka%2Fchat

diff --git a/src/main/java/de/juplo/kafka/chat/backend/domain/ShardNotOwnedException.java b/src/main/java/de/juplo/kafka/chat/backend/domain/ShardNotOwnedException.java
index d467eabb..3b638331 100644
--- a/src/main/java/de/juplo/kafka/chat/backend/domain/ShardNotOwnedException.java
+++ b/src/main/java/de/juplo/kafka/chat/backend/domain/ShardNotOwnedException.java
@@ -2,67 +2,16 @@ package de.juplo.kafka.chat.backend.domain;
 
 import lombok.Getter;
 
-import java.util.Arrays;
-import java.util.Collection;
-import java.util.Iterator;
-import java.util.stream.Collectors;
-
 
 public class ShardNotOwnedException extends IllegalStateException
 {
-  @Getter
-  private final ChatHomeService chatHomeService;
-  @Getter
-  private final ChatRoomInfo chatRoomInfo;
   @Getter
   private final int shard;
-  @Getter
-  private final int[] ownedShards;
 
 
-  public ShardNotOwnedException(
-      ChatHomeService chatHomeService,
-      ChatRoomInfo chatRoomInfo,
-      int shard,
-      Collection<Integer> ownedShards)
+  public ShardNotOwnedException(int shard)
   {
-    this(
-        chatHomeService,
-        chatRoomInfo,
-        shard,
-        ShardNotOwnedException.toArray(ownedShards));
-  }
-
-  public ShardNotOwnedException(
-      ChatHomeService chatHomeService,
-      ChatRoomInfo chatRoomInfo,
-      int shard,
-      int[] ownedShards)
-  {
-    super(
-        chatHomeService +
-        " does not own the shard " +
-        shard +
-        " for ChatRoom " +
-        chatRoomInfo +
-        " owned shards: " +
-        Arrays
-            .stream(ownedShards)
-            .mapToObj(ownedShard -> Integer.toString(ownedShard))
-            .collect(Collectors.joining(", ")));
-    this.chatHomeService = chatHomeService;
-    this.chatRoomInfo = chatRoomInfo;
+    super("This instance does not own the shard " + shard);
     this.shard = shard;
-    this.ownedShards = ownedShards;
-  }
-
-
-  private static int[] toArray(Collection<Integer> collection)
-  {
-    int[] array = new int[collection.size()];
-    Iterator<Integer> iterator = collection.iterator();
-    for (int i = 0; iterator.hasNext(); i++)
-      array[i] = iterator.next();
-    return array;
   }
 }