Author: rajdavies
Date: Wed Apr 9 11:37:26 2008
New Revision: 646477
URL: http://svn.apache.org/viewvc?rev=646477&view=rev
Log:
Fix for https://issues.apache.org/activemq/browse/AMQ-1103
Modified:
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQMessageConsumer.java
Modified:
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQMessageConsumer.java
URL:
http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQMessageConsumer.java?rev=646477&r1=646476&r2=646477&view=diff
==============================================================================
---
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQMessageConsumer.java
(original)
+++
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQMessageConsumer.java
Wed Apr 9 11:37:26 2008
@@ -165,6 +165,9 @@
throw new InvalidDestinationException(
"Cannot use a Temporary
destination that has been deleted");
}
+ if (prefetch < 0) {
+ throw new JMSException("Cannot have a prefetch size less than
zero");
+ }
}
this.session = session;