Re: 50k + messages stuck in queue with all consumers blocking on receive

2010-02-15 Thread Maarten_D
Hi Rob, Sorry, I'd killed that particular JVM before I read your request, and the error hasn't reoccurred since then. Something else that I've been thinking about since reading a http://tmielke.blogspot.com/2009/12/using-spring-jms-template-for-sending.html blog post : we used the ActiveMQ

Re: Topic-expired Messages are still in the Queue

2010-02-15 Thread Gary Tully
does the advice on slow consumer handinghttp://activemq.apache.org/slow-consumer-handling.html help? On 12 February 2010 14:02, AGT ajitgu...@hotmail.com wrote: We are using Topic to send and consume messages. All Messages which are expired but still in the Topic . The size of queue is

Locale dependent reflection methods.

2010-02-15 Thread akos
Hi, I've found a small bug in amq. The org.apache.activemq.util.IntrospectionSupport.findSetterMethod uses name.substring(0, 1).toUpperCase(). What is local dependent. For example in turkish locale we won't get setter for 'initialReconnectDelay', because the uppercase of 'i' is not 'I'. I would

Re: How to configure 5.3 broker over KahaDB to support lots of unconsumed persistent msgs?

2010-02-15 Thread scot.hale
I am trying to setup a queue with the following requirements: ActiveMQ 5.1 or 5.3 ( I have been testing with 5.3 ) 1. ) VM Transport 2. ) Persistent with KahaPersistenceAdaptor 4. ) JVM Memory usage is capped at something like 64MB - When this limit is reached the producers should

Re: OOM with high KahaDB index time

2010-02-15 Thread rideallday
Yes, topics are durable. Test case: 1. publish messages to queue, let several hundred thousand accumulate. 2. publish topics to queue, let several hundred thousand accumulate 3. begin consuming from queue. 4. begin consuming from topic. You should see a huge degrade in performance and a bunch

Re: ActiveMQ reconnect issue with consumer.prefetchSize=0

2010-02-15 Thread Gary Tully
Have not looked into the test case yet, but when prefetch=0, a consumer is polling for messages. The broker will not actively dispatch messages to that consumer. On each call to receive, the consumer sends a pull command to the broker and then waits for a message dispatch. If failover occurs

Re: Locale dependent reflection methods.

2010-02-15 Thread Gary Tully
thanks for the input. Can you raise an jira for this bug so it is not lost? On 15 February 2010 13:35, akos akos.ba...@p92.hu wrote: Hi, I've found a small bug in amq. The org.apache.activemq.util.IntrospectionSupport.findSetterMethod uses name.substring(0, 1).toUpperCase(). What is local

Re: How to configure 5.3 broker over KahaDB to support lots of unconsumed persistent msgs?

2010-02-15 Thread scot.hale
A.) I tried using the FilePendingQueueMessageStoragePolicy. I assume that this needs to be added to the queue destination policy specifically. However I added it to default and Topic just to be sure (not shown here). I turned on flow control, but was unable to figure out what memory settings

Re: How to configure 5.3 broker over KahaDB to support lots of unconsumed persistent msgs?

2010-02-15 Thread Mats Henrikson
Gary, I've been trying to do pretty much the same thing that Scott is trying to do, and I can't get it to work either - no matter what I do I seem to be able to blow the broker up with an OOME. What I want to do is configure my broker so that it becomes impossible to run it out of memory or lock

Re: 50k + messages stuck in queue with all consumers blocking on receive

2010-02-15 Thread Bruce Snyder
On Mon, Feb 15, 2010 at 4:41 AM, Maarten_D maarten.dir...@gmail.com wrote: Hi Rob, Sorry, I'd killed that particular JVM before I read your request, and the error hasn't reoccurred since then. Something else that I've been thinking about since reading a

Java - C openwire communication using ActiveMQ

2010-02-15 Thread krishna81m
I could get a Java - JMS - Java queue example ready in a couple of hours. How would I go about deploying the Java - JMS - C using openwire-c, where the C client is both consumer and producer? I do not see any better examples available here, regarding the configuration. There is one example at

Re: problems with openwire C library

2010-02-15 Thread krishna81m
How come many of the openwire-c error messages like this were unanswered and the last commit was in 2006. Are there any test cases for this API? mr2 wrote: Dear all, I'm trying to get the activemq/openwire-c demo application from apache activeMQ website work but I'm experiencing a

Re: https

2010-02-15 Thread Dejan Bosanac
Hi, needClientAuth parameter is not implemented for the https protocol. Cheers -- Dejan Bosanac - http://twitter.com/dejanb Open Source Integration - http://fusesource.com/ ActiveMQ in Action - http://www.manning.com/snyder/ Blog - http://www.nighttale.net On Fri, Feb 12, 2010 at 2:18 PM,