{
consumer.accept(
"peter",
- "Hallo");
+ "{\"user\":\"peter\",\"word\":\"Hallo\"}");
consumer.accept(
"klaus",
- "Müsch");
+ "{\"user\":\"klaus\",\"word\":\"Müsch\"}");
consumer.accept(
"peter",
- "Welt");
+ "{\"user\":\"peter\",\"word\":\"Welt\"}");
consumer.accept(
"klaus",
- "Müsch");
+ "{\"user\":\"klaus\",\"word\":\"Müsch\"}");
consumer.accept(
"klaus",
- "s");
+ "{\"user\":\"klaus\",\"word\":\"s\"}");
consumer.accept(
"peter",
- "Boäh");
+ "{\"user\":\"peter\",\"word\":\"Boäh\"}");
consumer.accept(
"peter",
- "Welt");
+ "{\"user\":\"peter\",\"word\":\"Welt\"}");
consumer.accept(
"peter",
- "Boäh");
+ "{\"user\":\"peter\",\"word\":\"Boäh\"}");
consumer.accept(
"klaus",
- "s");
+ "{\"user\":\"klaus\",\"word\":\"s\"}");
consumer.accept(
"peter",
- "Boäh");
+ "{\"user\":\"peter\",\"word\":\"Boäh\"}");
consumer.accept(
"klaus",
- "s");
+ "{\"user\":\"klaus\",\"word\":\"s\"}");
}
static void assertExpectedResult(List<Message> receivedMessages)
static Message[] expectedMessages =
{
Message.of(
- "{\"username\":\"peter\",\"word\":\"Hallo\"}",
- "1"),
+ "{\"user\":\"peter\",\"word\":\"Hallo\"}",
+ "{\"user\":\"peter\",\"word\":\"Hallo\",\"count\":1}"),
Message.of(
- "{\"username\":\"klaus\",\"word\":\"Müsch\"}",
- "1"),
+ "{\"user\":\"klaus\",\"word\":\"Müsch\"}",
+ "{\"user\":\"klaus\",\"word\":\"Müsch\",\"count\":1}"),
Message.of(
- "{\"username\":\"peter\",\"word\":\"Welt\"}",
- "1"),
+ "{\"user\":\"peter\",\"word\":\"Welt\"}",
+ "{\"user\":\"peter\",\"word\":\"Welt\",\"count\":1}"),
Message.of(
- "{\"username\":\"klaus\",\"word\":\"Müsch\"}",
- "2"),
+ "{\"user\":\"klaus\",\"word\":\"Müsch\"}",
+ "{\"user\":\"klaus\",\"word\":\"Müsch\",\"count\":2}"),
Message.of(
- "{\"username\":\"klaus\",\"word\":\"s\"}",
- "1"),
+ "{\"user\":\"klaus\",\"word\":\"s\"}",
+ "{\"user\":\"klaus\",\"word\":\"s\",\"count\":1}"),
Message.of(
- "{\"username\":\"peter\",\"word\":\"Boäh\"}",
- "1"),
+ "{\"user\":\"peter\",\"word\":\"Boäh\"}",
+ "{\"user\":\"peter\",\"word\":\"Boäh\",\"count\":1}"),
Message.of(
- "{\"username\":\"peter\",\"word\":\"Welt\"}",
- "2"),
+ "{\"user\":\"peter\",\"word\":\"Welt\"}",
+ "{\"user\":\"peter\",\"word\":\"Welt\",\"count\":2}"),
Message.of(
- "{\"username\":\"peter\",\"word\":\"Boäh\"}",
- "2"),
+ "{\"user\":\"peter\",\"word\":\"Boäh\"}",
+ "{\"user\":\"peter\",\"word\":\"Boäh\",\"count\":2}"),
Message.of(
- "{\"username\":\"klaus\",\"word\":\"s\"}",
- "2"),
+ "{\"user\":\"klaus\",\"word\":\"s\"}",
+ "{\"user\":\"klaus\",\"word\":\"s\",\"count\":2}"),
Message.of(
- "{\"username\":\"peter\",\"word\":\"Boäh\"}",
- "3"),
+ "{\"user\":\"peter\",\"word\":\"Boäh\"}",
+ "{\"user\":\"peter\",\"word\":\"Boäh\",\"count\":3}"),
Message.of(
- "{\"username\":\"klaus\",\"word\":\"s\"}",
- "3"),
+ "{\"user\":\"klaus\",\"word\":\"s\"}",
+ "{\"user\":\"klaus\",\"word\":\"s\",\"count\":3}"),
};
}