diff options
Diffstat (limited to 'src/main/java/derms/net/tomulticast/Receive.java')
| -rw-r--r-- | src/main/java/derms/net/tomulticast/Receive.java | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/main/java/derms/net/tomulticast/Receive.java b/src/main/java/derms/net/tomulticast/Receive.java index f95ee5f..06db127 100644 --- a/src/main/java/derms/net/tomulticast/Receive.java +++ b/src/main/java/derms/net/tomulticast/Receive.java @@ -41,7 +41,7 @@ class Receive<T extends MessagePayload> extends TotalOrderMulticast<T> implement while (!holdback.isEmpty()) { // Messages with lower sequence numbers are removed from the priority queue first. Message<T> msg = holdback.peek(); - if (msg == null || msg.seq != seq+1) + if (msg == null || msg.seq != seq) return; // This is the next element in the sequence; deliver it. |