projects
/
demos
/
kafka
/
wordcount
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
top10: 1.2.1 - `TestData` uses faked foreign classes for input-/output data
[demos/kafka/wordcount]
/
src
/
test
/
java
/
de
/
juplo
/
kafka
/
wordcount
/
top10
/
Top10ApplicationIT.java
diff --git
a/src/test/java/de/juplo/kafka/wordcount/top10/Top10ApplicationIT.java
b/src/test/java/de/juplo/kafka/wordcount/top10/Top10ApplicationIT.java
index
1bec92d
..
5e1f45c
100644
(file)
--- a/
src/test/java/de/juplo/kafka/wordcount/top10/Top10ApplicationIT.java
+++ b/
src/test/java/de/juplo/kafka/wordcount/top10/Top10ApplicationIT.java
@@
-128,7
+128,7
@@
public class Top10ApplicationIT
static class Consumer
{
static class Consumer
{
- private final MultiValueMap<
User,
Ranking> received = new LinkedMultiValueMap<>();
+ private final MultiValueMap<
TestUser, Test
Ranking> received = new LinkedMultiValueMap<>();
@KafkaListener(groupId = "TEST", topics = TOPIC_OUT)
public synchronized void receive(
@KafkaListener(groupId = "TEST", topics = TOPIC_OUT)
public synchronized void receive(
@@
-136,10
+136,10
@@
public class Top10ApplicationIT
@Payload TestRanking ranking)
{
log.debug("Received message: {} -> {}", user, ranking);
@Payload TestRanking ranking)
{
log.debug("Received message: {} -> {}", user, ranking);
- received.add(
User.of(user.getUser()), Ranking.of(ranking.getEntries())
);
+ received.add(
user, ranking
);
}
}
- synchronized MultiValueMap<
User,
Ranking> getReceivedMessages()
+ synchronized MultiValueMap<
TestUser, Test
Ranking> getReceivedMessages()
{
return received;
}
{
return received;
}