for (int message = 1; message <= number; message++)
{
Bytes value = new Bytes(stringSerializer.serialize(TOPIC, Integer.toString(message)));
send(key, value, logicErrors, messageSender);
}
for (int message = 1; message <= number; message++)
{
Bytes value = new Bytes(stringSerializer.serialize(TOPIC, Integer.toString(message)));
send(key, value, logicErrors, messageSender);
}