1 package de.juplo.kafka.chat.backend.domain;
5 import java.util.Arrays;
6 import java.util.Optional;
8 import java.util.stream.Collectors;
11 public class UnknownChatroomException extends IllegalStateException
14 private final UUID chatroomId;
16 private final Optional<Integer> shard;
18 private final Optional<int[]> ownedShards;
20 public UnknownChatroomException(UUID chatroomId)
22 super("Chatroom does not exist: " + chatroomId);
23 this.chatroomId = chatroomId;
24 this.shard = Optional.empty();
25 this.ownedShards = Optional.empty();
28 public UnknownChatroomException(UUID chatroomId, int shard, int[] ownedShards)
31 "Chatroom does not exist (here): " +
38 .mapToObj(ownedShard -> Integer.toString(ownedShard))
39 .collect(Collectors.joining(",")));
40 this.chatroomId = chatroomId;
41 this.shard = Optional.of(shard);
42 this.ownedShards = Optional.of(ownedShards);