We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent d72990c commit dac415cCopy full SHA for dac415c
simulator/src/main/java/byzzbench/simulator/faults/behaviors/ByzzFuzzDropMessageBehavior.java
@@ -100,8 +100,9 @@ public void accept(FaultContext context) {
100
if (router.haveConnectivity(sender, recipient)) {
101
return;
102
}
103
-
104
- // otherwise, drop the message: the sender and recipient are in different partitions
105
- context.getScenario().getTransport().dropEvent(e.getEventId());
+ if(e.getStatus() == Event.Status.QUEUED) {
+ // otherwise, drop the message: the sender and recipient are in different partitions
+ context.getScenario().getTransport().dropEvent(e.getEventId());
106
+ }
107
108
0 commit comments