summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorRobert Gemmell <robbie@apache.org>2010-12-20 10:47:59 +0000
committerRobert Gemmell <robbie@apache.org>2010-12-20 10:47:59 +0000
commit06c111fc3acf418087849f7d6a996da9578abe68 (patch)
tree82c1bf88e3354a31b60f9d9171c446841a19a282
parentc3d7af006982d495025164d4b1c05c1e670cb148 (diff)
downloadqpid-python-06c111fc3acf418087849f7d6a996da9578abe68.tar.gz
QPID-2971: prevent usage on autodelete queues, mirroring broker side behaviour for DLQs
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/0.5.x-dev@1051047 13f79535-47bb-0310-9956-ffa450edef68
-rw-r--r--qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer.java2
1 files changed, 1 insertions, 1 deletions
diff --git a/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer.java b/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer.java
index 0e5eb3b3d9..3b649e41d2 100644
--- a/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer.java
+++ b/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer.java
@@ -179,7 +179,7 @@ public abstract class BasicMessageConsumer<U> extends Closeable implements Messa
int idMapSize = Integer.getInteger(ClientProperties.MAX_DELIVERY_RECORDS_PROP_NAME, Math.max(2 * _prefetchHigh, 20));
Integer maxDeliveries = destination.getMaxDeliveryCount();
_maxDeliveryAttempts = maxDeliveries == null ? connection.getMaxDeliveryCount() : maxDeliveries;
- _maxRedeliverEnabled = _maxDeliveryAttempts > 0;
+ _maxRedeliverEnabled = _maxDeliveryAttempts > 0 && !destination.isAutoDelete();
_tracker = isMaxDeliveryCountEnforced() ? new DeliveryCountTracker(idMapSize) : null;
}