From eae3fc1956bbfeba31189419e40e8c1cb26a1668 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Mon, 19 Feb 2024 14:31:21 +0100 Subject: [PATCH] feat: Added log message for disabled storage --- .../storage/nostorage/NoStorageStorageStrategy.java | 9 +++++++++ 1 file changed, 9 insertions(+) diff --git a/src/main/java/de/juplo/kafka/chat/backend/storage/nostorage/NoStorageStorageStrategy.java b/src/main/java/de/juplo/kafka/chat/backend/storage/nostorage/NoStorageStorageStrategy.java index 79f36d79..6ca08e22 100644 --- a/src/main/java/de/juplo/kafka/chat/backend/storage/nostorage/NoStorageStorageStrategy.java +++ b/src/main/java/de/juplo/kafka/chat/backend/storage/nostorage/NoStorageStorageStrategy.java @@ -1,15 +1,24 @@ package de.juplo.kafka.chat.backend.storage.nostorage; +import de.juplo.kafka.chat.backend.domain.ChatHomeService; import de.juplo.kafka.chat.backend.domain.ChatRoomInfo; import de.juplo.kafka.chat.backend.domain.Message; import de.juplo.kafka.chat.backend.implementation.StorageStrategy; +import lombok.extern.slf4j.Slf4j; import reactor.core.publisher.Flux; import java.util.UUID; +@Slf4j public class NoStorageStorageStrategy implements StorageStrategy { + @Override + public void write(ChatHomeService chatHomeService) + { + log.info("Storage is disabled: Not storing {}", chatHomeService); + } + @Override public void writeChatRoomInfo(Flux chatRoomInfoFlux) {} -- 2.20.1