- Bytes value =
- poisonPills.contains(i)
- ? new Bytes(stringSerializer.serialize(TOPIC, "BOOM!"))
- : new Bytes(longSerializer.serialize(TOPIC, (long)i));
+ Bytes value = new Bytes(longSerializer.serialize(TOPIC, (long)i));
+ if (logicErrors.contains(i))
+ {
+ value = new Bytes(longSerializer.serialize(TOPIC, Long.MIN_VALUE));
+ }
+ if (poisonPills.contains(i))
+ {
+ value = new Bytes(stringSerializer.serialize(TOPIC, "BOOM (Poison-Pill)!"));
+ }