This is an automated email from the ASF dual-hosted git repository.
tabish pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/qpid-protonj2.git
The following commit(s) were added to refs/heads/main by this push:
new 2aa2911b PROTON-2806 Construct the correct error message for wrong
delivery ID
2aa2911b is described below
commit 2aa2911be146d918642261d91f42696179abab07
Author: Timothy Bish <[email protected]>
AuthorDate: Thu Mar 14 18:00:41 2024 -0400
PROTON-2806 Construct the correct error message for wrong delivery ID
Use the correct expected value in the error message.
---
.../apache/qpid/protonj2/engine/impl/ProtonSessionIncomingWindow.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
diff --git
a/protonj2/src/main/java/org/apache/qpid/protonj2/engine/impl/ProtonSessionIncomingWindow.java
b/protonj2/src/main/java/org/apache/qpid/protonj2/engine/impl/ProtonSessionIncomingWindow.java
index d4acc17e..89db238b 100644
---
a/protonj2/src/main/java/org/apache/qpid/protonj2/engine/impl/ProtonSessionIncomingWindow.java
+++
b/protonj2/src/main/java/org/apache/qpid/protonj2/engine/impl/ProtonSessionIncomingWindow.java
@@ -246,10 +246,9 @@ public class ProtonSessionIncomingWindow {
if (lastDeliveryid == null) {
lastDeliveryid = new SequenceNumber((int) deliveryId);
} else {
- int previousId = lastDeliveryid.intValue();
if (lastDeliveryid.increment().compareTo((int) deliveryId) != 0) {
session.getConnection().getEngine().engineFailed(
- new ProtocolViolationException("Expected delivery-id " +
previousId + ", got " + deliveryId));
+ new ProtocolViolationException("Expected delivery-id " +
lastDeliveryid + ", got " + deliveryId));
}
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]