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, int shard)
+ {
+ log.info("Created SimpleChatHome for shard {}", shard);
+ this.service = service;
+ this.shard = shard;
+ }
+
public SimpleChatHome(ChatHomeService service)
{
this(service, 0);