You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by rg...@apache.org on 2012/04/18 10:15:25 UTC
svn commit: r1327422 -
/qpid/trunk/qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/MessageImpl.java
Author: rgodfrey
Date: Wed Apr 18 08:15:25 2012
New Revision: 1327422
URL: http://svn.apache.org/viewvc?rev=1327422&view=rev
Log:
QPID-3953 : [Java AMQP 1-0] Fix durable subscribers
Modified:
qpid/trunk/qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/MessageImpl.java
Modified: qpid/trunk/qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/MessageImpl.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/MessageImpl.java?rev=1327422&r1=1327421&r2=1327422&view=diff
==============================================================================
--- qpid/trunk/qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/MessageImpl.java (original)
+++ qpid/trunk/qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/MessageImpl.java Wed Apr 18 08:15:25 2012
@@ -251,9 +251,9 @@ public abstract class MessageImpl implem
UnsignedInteger failures = getDeliveryFailures();
if(redelivered)
{
- if(failures == null)
+ if(failures == null || UnsignedInteger.ZERO.equals(failures))
{
- setDeliveryFailures(UnsignedInteger.valueOf(1));
+ setDeliveryFailures(UnsignedInteger.ONE);
}
}
else
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org