X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fchat%2Fbackend%2Fimplementation%2Fkafka%2Fmessages%2FAbstractMessageTo.java;h=843a2c4545fcd1e4ab11716a72f942330bbcd4e0;hb=be27a128b7606623400e5ada1b23e6b19b4644ad;hp=7cc7541e6dd2ce79a0c106c3dd78b399683bf7c8;hpb=60777d1ca87e578e93ef29e6e4af98453ee199f9;p=demos%2Fkafka%2Fchat diff --git a/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/messages/AbstractMessageTo.java b/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/messages/AbstractMessageTo.java index 7cc7541e..843a2c45 100644 --- a/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/messages/AbstractMessageTo.java +++ b/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/messages/AbstractMessageTo.java @@ -1,4 +1,4 @@ -package de.juplo.kafka.chat.backend.persistence.kafka.messages; +package de.juplo.kafka.chat.backend.implementation.kafka.messages; import lombok.Getter; @@ -11,6 +11,9 @@ public class AbstractMessageTo public enum ToType { COMMAND_CREATE_CHATROOM, EVENT_CHATMESSAGE_RECEIVED, + EVENT_CHATROOM_CREATED, + EVENT_SHARD_ASSIGNED, + EVENT_SHARD_REVOKED, } @Getter