Fix for https://issues.apache.org/activemq/browse/AMQ-1103

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@646477 13f79535-47bb-0310-9956-ffa450edef68

activemq-core/src/main/java/org/apache/activemq/ActiveMQMessageConsumer.java

@@ -165,6 +165,9 @@ public class ActiveMQMessageConsumer implements MessageAvailableConsumer, StatsC
                 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;