private final long currentOffset;
private final long unseenOffset;
+ /**
+ * Wird nicht benötigt!!!
+ * Derzeit?
+ * @param consumer
+ * @param tp
+ * @param currentOffset
+ * @param unseenOffset
+ */
ChatRoomLoadingMessageHandlingStrategy(
Consumer consumer,
TopicPartition tp,
@Override
public Mono<Message> handleMessage(Message.MessageKey key, LocalDateTime timestamp, String text)
{
+ // TODO
return null;
}
}