X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fchat%2Fbackend%2Fimplementation%2Fkafka%2FChannelMediator.java;h=10176d32bbcf1a671273324056286bf94d12a8c6;hb=900422dccb5a92fbceac34caa5e614b0d7f05ad7;hp=d6e028a347c512e1e99083707c4507ae8b9cd745;hpb=300fb309b42aefecd475a75c946958e9b9316f7e;p=demos%2Fkafka%2Fchat

diff --git a/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/ChannelMediator.java b/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/ChannelMediator.java
index d6e028a3..10176d32 100644
--- a/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/ChannelMediator.java
+++ b/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/ChannelMediator.java
@@ -13,6 +13,8 @@ public class ChannelMediator
 {
   @Setter
   private InfoChannel infoChannel;
+  @Setter
+  private DataChannel dataChannel;
 
 
   void shardAssigned(int shard)
@@ -29,4 +31,9 @@ public class ChannelMediator
   {
     return infoChannel.getChatRoomInfo(id);
   }
+
+  void chatRoomCreated(ChatRoomInfo chatRoomInfo)
+  {
+    dataChannel.createChatRoomData(chatRoomInfo);
+  }
 }