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

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..95a8ff8 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("Listening to {} was completed!", chatRoom))
+              .doOnError(throwalbe -> log.error("Listening to {} failed!", chatRoom, throwalbe));
         });
   }