From 06c111fc3acf418087849f7d6a996da9578abe68 Mon Sep 17 00:00:00 2001 From: Robert Gemmell Date: Mon, 20 Dec 2010 10:47:59 +0000 Subject: 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 --- .../src/main/java/org/apache/qpid/client/BasicMessageConsumer.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 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; } -- cgit v1.2.1