Author: robbie
Date: Wed Oct 15 15:31:18 2014
New Revision: 1632091
URL: http://svn.apache.org/r1632091
Log:
PROTON-715: subtract 1 when setting delivery-count header based on
JMSXDeliveryCount during outbound Native transformation
Modified:
qpid/proton/trunk/contrib/proton-jms/src/main/java/org/apache/qpid/proton/jms/AMQPNativeOutboundTransformer.java
Modified:
qpid/proton/trunk/contrib/proton-jms/src/main/java/org/apache/qpid/proton/jms/AMQPNativeOutboundTransformer.java
URL:
http://svn.apache.org/viewvc/qpid/proton/trunk/contrib/proton-jms/src/main/java/org/apache/qpid/proton/jms/AMQPNativeOutboundTransformer.java?rev=1632091&r1=1632090&r2=1632091&view=diff
==============================================================================
---
qpid/proton/trunk/contrib/proton-jms/src/main/java/org/apache/qpid/proton/jms/AMQPNativeOutboundTransformer.java
(original)
+++
qpid/proton/trunk/contrib/proton-jms/src/main/java/org/apache/qpid/proton/jms/AMQPNativeOutboundTransformer.java
Wed Oct 15 15:31:18 2014
@@ -81,7 +81,9 @@ public class AMQPNativeOutboundTransform
}
// Update the DeliveryCount header...
- amqp.getHeader().setDeliveryCount(new UnsignedInteger(count));
+ // The AMQP delivery-count field only includes prior failed
delivery attempts,
+ // whereas JMSXDeliveryCount includes the first/current
delivery attempt. Subtract 1.
+ amqp.getHeader().setDeliveryCount(new UnsignedInteger(count -
1));
// Re-encode...
ByteBuffer buffer = ByteBuffer.wrap(new byte[1024*4]);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
