You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by Pradeep <pr...@gmail.com> on 2012/02/20 06:30:42 UTC

Getting IllegalArgumentException in activemq console when prefetch is set to zero

Hi,

We dont want any prefetch to happen in our application. So, we configured as

*broker.properties :*
'tcp://localhost:61616?jms.prefetchPolicy.queuePrefetch=0'.

(or)

session.createQueue(queueName?consumer.prefetchSize=0); 


Prefetch is not happening (working as expected) but we are getting
illegalArgumentException in activemq console. Here's the full stack trace.

Java Runtime: Sun Microsystems Inc. 1.6.0_22 C:\Program
Files\Java\jdk1.6.0_22\jre
  Heap sizes: current=15872k  free=13226k  max=506816k
    JVM args: -Dcom.sun.management.jmxremote -Xmx512M
-Dorg.apache.activemq.UseDedicatedTaskRunner=true -Djava.util.logg
ing.config.file=logging.properties
-Dactivemq.classpath=D:\apache-activemq-5.5.1\bin\../conf;D:\apache-activemq-5.5.1\bi
n\../conf; -Dactivemq.home=D:\apache-activemq-5.5.1\bin\..
-Dactivemq.base=D:\apache-activemq-5.5.1\bin\..
ACTIVEMQ_HOME: D:\apache-activemq-5.5.1\bin\..
ACTIVEMQ_BASE: D:\apache-activemq-5.5.1\bin\..
Loading message broker from: xbean:activemq.xml
 INFO | Refreshing org.apache.activemq.xbean.XBeanBrokerFactory$1@17a29a1:
startup date [Thu Feb 16 18:35:44 GMT+05:30 2
012]; root of context hierarchy
 WARN | destroyApplicationContextOnStop parameter is deprecated, please use
shutdown hooks instead
 INFO |
PListStore:D:\apache-activemq-5.5.1\bin\..\data\localhost\tmp_storage
started
 INFO | Using Persistence Adapter:
KahaDBPersistenceAdapter[D:\apache-activemq-5.5.1\bin\..\data\kahadb]
 INFO | KahaDB is version 3
 INFO | Recovering from the journal ...
 INFO | Recovery replayed 1 operations from the journal in 0.031 seconds.
 INFO | ActiveMQ 5.5.1 JMS Message Broker (localhost) is starting
 INFO | For help or more information please see: http://activemq.apache.org/
 INFO | Listening for connections at: tcp://riteshp:61616
 INFO | Connector openwire Started
 INFO | ActiveMQ JMS Message Broker (localhost,
ID:riteshp-1420-1329397545753-0:1) started
 INFO | jetty-7.1.6.v20100715
 INFO | ActiveMQ WebConsole initialized.
 INFO | Initializing Spring FrameworkServlet 'dispatcher'
 INFO | ActiveMQ Console at http://0.0.0.0:8161/admin
 INFO | ActiveMQ Web Demos at http://0.0.0.0:8161/demo
 INFO | RESTful file access application at http://0.0.0.0:8161/fileserver
 INFO | Started SelectChannelConnector@0.0.0.0:8161
 WARN | Async error occurred: java.lang.IllegalArgumentException: Illegal
execution time.
java.lang.IllegalArgumentException: Illegal execution time.
        at java.util.Timer.sched(Timer.java:350)
        at java.util.Timer.schedule(Timer.java:170)
        at
org.apache.activemq.thread.Scheduler.executeAfterDelay(Scheduler.java:63)
        at
org.apache.activemq.broker.region.PrefetchSubscription.pullMessage(PrefetchSubscription.java:115)
        at
org.apache.activemq.broker.region.AbstractRegion.messagePull(AbstractRegion.java:391)
        at
org.apache.activemq.broker.region.RegionBroker.messagePull(RegionBroker.java:557)
        at
org.apache.activemq.broker.BrokerFilter.messagePull(BrokerFilter.java:81)
        at
org.apache.activemq.broker.BrokerFilter.messagePull(BrokerFilter.java:81)
        at
org.apache.activemq.broker.BrokerFilter.messagePull(BrokerFilter.java:81)
        at
org.apache.activemq.broker.MutableBrokerFilter.messagePull(MutableBrokerFilter.java:245)
        at
org.apache.activemq.broker.TransportConnection.processMessagePull(TransportConnection.java:470)
        at
org.apache.activemq.command.MessagePull.visit(MessagePull.java:43)
        at
org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:306)
        at
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:179)
        at
org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:69)
        at
org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:113)
        at
org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:227)
        at
org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)
        at
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:220)
        at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:202)
        at java.lang.Thread.run(Thread.java:662)

Getting the above exception, while executing create queue statement. 

Awaiting your quick response.

Thanks.



--
View this message in context: http://activemq.2283324.n4.nabble.com/Getting-IllegalArgumentException-in-activemq-console-when-prefetch-is-set-to-zero-tp4403274p4403274.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Getting IllegalArgumentException in activemq console when prefetch is set to zero

Posted by Pradeep <pr...@gmail.com>.
Hi,

Missed a point: I am using activeMQ v5.5.1.

Thanks.


--
View this message in context: http://activemq.2283324.n4.nabble.com/Getting-IllegalArgumentException-in-activemq-console-when-prefetch-is-set-to-zero-tp4403274p4403280.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.