diff options
| author | Robert Godfrey <rgodfrey@apache.org> | 2012-04-18 08:15:25 +0000 |
|---|---|---|
| committer | Robert Godfrey <rgodfrey@apache.org> | 2012-04-18 08:15:25 +0000 |
| commit | 3e4f233b2b5e89ba5600cba910bbc5db1d8b0a3a (patch) | |
| tree | b3bdcc9c69e89f43c352c34e304de313df35461a | |
| parent | b490ce78d2954c6c32db6526dd4889900ec10e5b (diff) | |
| download | qpid-python-3e4f233b2b5e89ba5600cba910bbc5db1d8b0a3a.tar.gz | |
QPID-3953 : [Java AMQP 1-0] Fix durable subscribers
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1327422 13f79535-47bb-0310-9956-ffa450edef68
| -rw-r--r-- | java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/MessageImpl.java | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/MessageImpl.java b/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/MessageImpl.java index dc392f967e..f1056b94fd 100644 --- a/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/MessageImpl.java +++ b/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/MessageImpl.java @@ -251,9 +251,9 @@ public abstract class MessageImpl implements Message UnsignedInteger failures = getDeliveryFailures();
if(redelivered)
{
- if(failures == null)
+ if(failures == null || UnsignedInteger.ZERO.equals(failures))
{
- setDeliveryFailures(UnsignedInteger.valueOf(1));
+ setDeliveryFailures(UnsignedInteger.ONE);
}
}
else
|