juplo.de Git - demos/kafka/chat/blob - src/main/java/de/juplo/kafka/chat/backend/domain/exceptions/ShardNotOwnedException.java

   1 package de.juplo.kafka.chat.backend.domain.exceptions;
   2
   3 import lombok.Getter;
   4
   5
   6 public class ShardNotOwnedException extends IllegalStateException
   7 {
   8   @Getter
   9   private final String instanceId;
  10   @Getter
  11   private final int shard;
  12
  13
  14   public ShardNotOwnedException(String instanceId, int shard)
  15   {
  16     super("Instance " + instanceId + " does not own the shard " + shard);
  17     this.instanceId = instanceId;
  18     this.shard = shard;
  19   }
  20 }