X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;ds=sidebyside;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fchat%2Fbackend%2Fdomain%2FChatRoomData.java;fp=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fchat%2Fbackend%2Fdomain%2FChatRoomData.java;h=20c046d810a37231ba2a5a693db9ac7129b12aea;hb=8300dcd98f681893a077051560151a8f1b94e38d;hp=ca33aca58fcc901d2d3784b1623283dcd08c918e;hpb=900422dccb5a92fbceac34caa5e614b0d7f05ad7;p=demos%2Fkafka%2Fchat

diff --git a/src/main/java/de/juplo/kafka/chat/backend/domain/ChatRoomData.java b/src/main/java/de/juplo/kafka/chat/backend/domain/ChatRoomData.java
index ca33aca5..20c046d8 100644
--- a/src/main/java/de/juplo/kafka/chat/backend/domain/ChatRoomData.java
+++ b/src/main/java/de/juplo/kafka/chat/backend/domain/ChatRoomData.java
@@ -24,7 +24,7 @@ public class ChatRoomData
   private final Clock clock;
   private final int historyLimit;
   private Sinks.Many<Message> sink;
-  private volatile boolean active = true;
+  private volatile boolean active = false;
 
 
   public ChatRoomData(
@@ -114,6 +114,12 @@ public class ChatRoomData
 
   public void activate()
   {
+    if (active)
+    {
+      log.info("{} is already active!", service.getChatRoomId());
+      return;
+    }
+
     log.info("{} is being activated", service.getChatRoomId());
     this.sink = createSink();
     active = true;