Apache/activemq
1
0
Fork 0
mirror of https://github.com/apache/activemq.git synced 2025-02-17 07:24:51 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix for https://issues.apache.org/jira/browse/AMQ-3242

Browse Source 
Make the max value actually be Short.MAX_VALUE

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1174954 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Timothy A. Bish 2011-09-23 18:58:55 +00:00
parent ca90cc7b8c
commit fef66a6e98
1 changed files with 7 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
activemq-core/src/main/java/org/apache/activemq/ActiveMQPrefetchPolicy.java
View File

@ -22,21 +22,22 @@ import org.slf4j.LoggerFactory;
/** /**
* Defines the prefetch message policies for different types of consumers * Defines the prefetch message policies for different types of consumers
* *
* @org.apache.xbean.XBean element="prefetchPolicy" * @org.apache.xbean.XBean element="prefetchPolicy"
* *
*/ */
@SuppressWarnings("serial")
public class ActiveMQPrefetchPolicy extends Object implements Serializable { public class ActiveMQPrefetchPolicy extends Object implements Serializable {
public static final int MAX_PREFETCH_SIZE = Short.MAX_VALUE - 1; public static final int MAX_PREFETCH_SIZE = Short.MAX_VALUE;
public static final int DEFAULT_QUEUE_PREFETCH = 1000; public static final int DEFAULT_QUEUE_PREFETCH = 1000;
public static final int DEFAULT_QUEUE_BROWSER_PREFETCH = 500; public static final int DEFAULT_QUEUE_BROWSER_PREFETCH = 500;
public static final int DEFAULT_DURABLE_TOPIC_PREFETCH = 100; public static final int DEFAULT_DURABLE_TOPIC_PREFETCH = 100;
public static final int DEFAULT_OPTIMIZE_DURABLE_TOPIC_PREFETCH=1000; public static final int DEFAULT_OPTIMIZE_DURABLE_TOPIC_PREFETCH=1000;
public static final int DEFAULT_INPUT_STREAM_PREFETCH=100; public static final int DEFAULT_INPUT_STREAM_PREFETCH=100;
public static final int DEFAULT_TOPIC_PREFETCH = MAX_PREFETCH_SIZE; public static final int DEFAULT_TOPIC_PREFETCH = MAX_PREFETCH_SIZE;
private static final Logger LOG = LoggerFactory.getLogger(ActiveMQPrefetchPolicy.class); private static final Logger LOG = LoggerFactory.getLogger(ActiveMQPrefetchPolicy.class);
private int queuePrefetch; private int queuePrefetch;
private int queueBrowserPrefetch; private int queueBrowserPrefetch;
private int topicPrefetch; private int topicPrefetch;
@ -164,7 +165,7 @@ public class ActiveMQPrefetchPolicy extends Object implements Serializable {
public void setInputStreamPrefetch(int inputStreamPrefetch) { public void setInputStreamPrefetch(int inputStreamPrefetch) {
this.inputStreamPrefetch = getMaxPrefetchLimit(inputStreamPrefetch); this.inputStreamPrefetch = getMaxPrefetchLimit(inputStreamPrefetch);
} }
public boolean equals(Object object){ public boolean equals(Object object){
if (object instanceof ActiveMQPrefetchPolicy){ if (object instanceof ActiveMQPrefetchPolicy){
ActiveMQPrefetchPolicy other = (ActiveMQPrefetchPolicy) object; ActiveMQPrefetchPolicy other = (ActiveMQPrefetchPolicy) object;