.mapToObj(i -> "seeräuber-" + i)
.toArray(i -> new String[i]);
final StringSerializer stringSerializer = new StringSerializer();
- final Bytes startMessage = new Bytes(stringSerializer.serialize(TOPIC, "START"));
- final Bytes endMessage = new Bytes(stringSerializer.serialize(TOPIC, "END"));
+ final Bytes calculateMessage = new Bytes(stringSerializer.serialize(TOPIC, "CALCULATE"));
int counter = 0;
Bytes key = new Bytes(stringSerializer.serialize(TOPIC, seeräuber));
- send(key, startMessage, logicErrors, messageSender);
for (int message = 1; message <= number; message++)
{
Bytes value = new Bytes(stringSerializer.serialize(TOPIC, Integer.toString(message)));
send(key, value, logicErrors, messageSender);
}
- send(key, endMessage, logicErrors, messageSender);
+ send(key, calculateMessage, logicErrors, messageSender);
}
return counter;
{
if (logicErrors)
{
- value = value.equals(startMessage) ? endMessage : startMessage;
+ value = new Bytes(stringSerializer.serialize(TOPIC, Integer.toString(-1)));
}
}