X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fchat%2Fbackend%2Fdomain%2FShardNotOwnedException.java;h=452f26d15dd2c52f86cfb34e13308750e25ee056;hb=a5b72cd8868eb96b5282643d423d0ced8dabf069;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..452f26d1 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
@@ -1,68 +1,18 @@
 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;
+import org.apache.kafka.common.TopicPartition;
 
 
 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)
-  {
-    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;
-    this.shard = shard;
-    this.ownedShards = ownedShards;
-  }
+  private final TopicPartition topicPartition;
 
 
-  private static int[] toArray(Collection<Integer> collection)
+  public ShardNotOwnedException(TopicPartition topicPartition)
   {
-    int[] array = new int[collection.size()];
-    Iterator<Integer> iterator = collection.iterator();
-    for (int i = 0; iterator.hasNext(); i++)
-      array[i] = iterator.next();
-    return array;
+    super("This instance does not own the shard for " + topicPartition);
+    this.topicPartition = topicPartition;
   }
 }