test: HandoverIT-POC - Added logging for complete/error to listener

[demos/kafka/chat] / src / test / java / de / juplo / kafka / chat / backend / TestListener.java

diff --git a/src/test/java/de/juplo/kafka/chat/backend/TestListener.java b/src/test/java/de/juplo/kafka/chat/backend/TestListener.java
index 78d4c82..e58cb2b 100644 (file)
--- a/src/test/java/de/juplo/kafka/chat/backend/TestListener.java
+++ b/src/test/java/de/juplo/kafka/chat/backend/TestListener.java
@@ -28,7 +28,7 @@ public class TestListener
         .fromArray(chatRooms)
         .flatMap(chatRoom ->
         {
-          log.info("Requesting messages from chat-room {}", chatRoom);
+          log.info("Requesting messages for chat-room {}", chatRoom);
           List<MessageTo> list = new LinkedList<>();
           receivedMessages.put(chatRoom.getId(), list);
           return receiveMessages(chatRoom)
@@ -43,7 +43,9 @@ public class TestListener
                   return Mono.error(e);
                 }
               })
-              .doOnNext(message -> list.add(message));
+              .doOnNext(message -> list.add(message))
+              .doOnComplete(() -> log.info("{} was completed!", chatRoom))
+              .doOnError(throwalbe -> log.error("{} failed: {}", chatRoom, throwalbe));
         });
   }