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-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org