import de.juplo.kafka.chat.backend.domain.exceptions.InvalidUsernameException;
import de.juplo.kafka.chat.backend.domain.exceptions.MessageMutationException;
import lombok.extern.slf4j.Slf4j;
import de.juplo.kafka.chat.backend.domain.exceptions.InvalidUsernameException;
import de.juplo.kafka.chat.backend.domain.exceptions.MessageMutationException;
import lombok.extern.slf4j.Slf4j;
private final Clock clock;
private final int historyLimit;
private Sinks.Many<Message> sink;
private final Clock clock;
private final int historyLimit;
private Sinks.Many<Message> sink;
// @RequiredArgsConstructor unfortunately not possible, because
// the `historyLimit` is not set, if `createSink()` is called
// from the variable declaration!
// @RequiredArgsConstructor unfortunately not possible, because
// the `historyLimit` is not set, if `createSink()` is called
// from the variable declaration!