X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fchat%2Fbackend%2Fdomain%2FChatRoomData.java;h=d783eb4ca2d6dd1b14908d5de8b2f44aad4303cd;hb=46cafb65876ccec33ef4e9948fad2e4aa526039a;hp=18ca0bf1fed42c7f9a8d2e05407ef2ef5d59ff99;hpb=2f37f03aac7010dcd2ea693c072c4b0102433c1e;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 18ca0bf1..d783eb4c 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
@@ -19,7 +19,7 @@ public class ChatRoomData
 {
   public final static Pattern VALID_USER = Pattern.compile("^[a-z0-9-]{2,}$");
 
-  private final ChatRoomService service;
+  private final ChatMessageService service;
   private final Clock clock;
   private final int bufferSize;
   private Sinks.Many<Message> sink;
@@ -27,7 +27,7 @@ public class ChatRoomData
 
   public ChatRoomData(
       Clock clock,
-      ChatRoomService service,
+      ChatMessageService service,
       int bufferSize)
   {
     log.info("Created ChatRoom with buffer-size {}", bufferSize);
@@ -78,7 +78,7 @@ public class ChatRoomData
   }
 
 
-  public ChatRoomService getChatRoomService()
+  public ChatMessageService getChatRoomService()
   {
     return service;
   }