package de.juplo.kafka.chat.backend.domain;
-import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
@Slf4j
-@RequiredArgsConstructor
public class SimpleChatHome implements ChatHome
{
private final ChatHomeService service;
private final int shard;
- public SimpleChatHome(ChatHomeService service)
+ public SimpleChatHome(ChatHomeService service, int shard)
{
- this(service, 0);
+ log.info("Created SimpleChatHome for shard {}", shard);
+ this.service = service;
+ this.shard = shard;
}
-
- @Override
- public Mono<ChatRoom> putChatRoom(ChatRoom chatRoom)
+ public SimpleChatHome(ChatHomeService service)
{
- return service.putChatRoom(chatRoom);
+ this(service, 0);
}
+
@Override
public Mono<ChatRoom> getChatRoom(UUID id)
{