package de.juplo.kafka.chat.backend.domain;
+import de.juplo.kafka.chat.backend.domain.exceptions.InvalidUsernameException;
+import de.juplo.kafka.chat.backend.domain.exceptions.MessageMutationException;
import lombok.extern.slf4j.Slf4j;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
{
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;
public ChatRoomData(
Clock clock,
- ChatRoomService service,
+ ChatMessageService service,
int bufferSize)
{
log.info("Created ChatRoom with buffer-size {}", bufferSize);
}
- public ChatRoomService getChatRoomService()
+ public ChatMessageService getChatRoomService()
{
return service;
}