X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fchat%2Fbackend%2Fpersistence%2Fkafka%2FChatroomInactiveMessageHandlingStrategy.java;h=0da4111798fa55aefa399f3273bca6575139b9f4;hb=a5b72cd8868eb96b5282643d423d0ced8dabf069;hp=892da90d1c244146b48adc02cc03453965627a7f;hpb=dfe4f4f9b979b080ccb7c29af78a1c108c3040f4;p=demos%2Fkafka%2Fchat

diff --git a/src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/ChatroomInactiveMessageHandlingStrategy.java b/src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/ChatroomInactiveMessageHandlingStrategy.java
index 892da90d..0da41117 100644
--- a/src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/ChatroomInactiveMessageHandlingStrategy.java
+++ b/src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/ChatroomInactiveMessageHandlingStrategy.java
@@ -1,6 +1,7 @@
 package de.juplo.kafka.chat.backend.persistence.kafka;
 
 import de.juplo.kafka.chat.backend.domain.Message;
+import de.juplo.kafka.chat.backend.domain.ShardNotOwnedException;
 import lombok.RequiredArgsConstructor;
 import org.apache.kafka.common.TopicPartition;
 import reactor.core.publisher.Mono;
@@ -11,7 +12,7 @@ import java.time.LocalDateTime;
 @RequiredArgsConstructor
 class ChatroomInactiveMessageHandlingStrategy implements MessageHandlingStrategy
 {
-  private final TopicPartition tp;
+  private final TopicPartition topicPartition;
 
   @Override
   public Mono<Message> handleMessage(
@@ -19,6 +20,6 @@ class ChatroomInactiveMessageHandlingStrategy implements MessageHandlingStrategy
       LocalDateTime timestamp,
       String text)
   {
-    throw new 
+    throw new ShardNotOwnedException(topicPartition);
   }
 }