Author: robbie
Date: Fri Dec 10 15:00:08 2010
New Revision: 1044385
URL: http://svn.apache.org/viewvc?rev=1044385&view=rev
Log:
QPID-2971: impose a minimum on the default record count, to allow for cases
where pretech is very small
Modified:
qpid/branches/0.5.x-dev/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer.java
Modified:
qpid/branches/0.5.x-dev/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer.java
URL:
http://svn.apache.org/viewvc/qpid/branches/0.5.x-dev/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer.java?rev=1044385&r1=1044384&r2=1044385&view=diff
==============================================================================
---
qpid/branches/0.5.x-dev/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer.java
(original)
+++
qpid/branches/0.5.x-dev/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer.java
Fri Dec 10 15:00:08 2010
@@ -176,7 +176,7 @@ public abstract class BasicMessageConsum
}
//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;
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscr...@qpid.apache.org
