projects
/
demos
/
kafka
/
chat
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
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 ->
{
.fromArray(chatRooms)
.flatMap(chatRoom ->
{
- log.info("Requesting messages f
rom
chat-room {}", chatRoom);
+ log.info("Requesting messages f
or
chat-room {}", chatRoom);
List<MessageTo> list = new LinkedList<>();
receivedMessages.put(chatRoom.getId(), list);
return receiveMessages(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);
}
})
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));
});
}
});
}