diff options
| author | Robert Gemmell <robbie@apache.org> | 2010-12-10 15:00:08 +0000 |
|---|---|---|
| committer | Robert Gemmell <robbie@apache.org> | 2010-12-10 15:00:08 +0000 |
| commit | c4ab602008d26d0a5137da73768c91081ce89ef6 (patch) | |
| tree | 255368eb533514d9034a3507ec5059094d3ada3a | |
| parent | b8983f8dd7679688a8bdd75a47e5cf24ab2ce513 (diff) | |
| download | qpid-python-c4ab602008d26d0a5137da73768c91081ce89ef6.tar.gz | |
QPID-2971: impose a minimum on the default record count, to allow for cases where pretech is very small
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/0.5.x-dev@1044385 13f79535-47bb-0310-9956-ffa450edef68
| -rw-r--r-- | qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer.java | 2 |
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 92e9c3fd2d..d8ceb3278d 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 @@ -176,7 +176,7 @@ public abstract class BasicMessageConsumer<U> extends Closeable implements Messa } //set configuration + create tracker for Max Delivery Count - int idMapSize = Integer.getInteger(ClientProperties.MAX_DELIVERY_RECORDS_PROP_NAME, 2 * _prefetchHigh); + 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; |