Re: what to do when storage is full?

2012-10-02 Thread Lin Wen Tong
I moved the kahaDB path to a bigger space and it recovered: 2012-10-02 14:16:07,103 [main ] INFO MessageDatabase - @2056:22703857, 10 entries recovered .. 2012-10-02 14:16:17,142 [main ] INFO MessageDatabase - @2061:27448275, 20 entries r

Re: How to program composite queue by using its name?

2012-10-02 Thread Gary Tully
The virtual destination stuff is implemented on the broker, and it could be dynamic but would need some programatic support (extending the interceptor) to pick up changes at runtime. The simple composite destination name syntax using a coma separated list works just fine and is dynamic. On 2 Octo

Re: How to program composite queue by using its name?

2012-10-02 Thread Gary Tully
@htsang I have just run that test on trunk and it works as expected, the messages are forwarded and received from the expected destinations. Have a peek at the output and trace: http://pastebin.com/hRT7103x There must be some difference in your setup. On 2 October 2012 20:00, htsang4lo wrote: >

what to do when storage is full?

2012-10-02 Thread Lin Wen Tong
Hi All, I have load tested our activeMQ (5.6.0) and our shared drive is 99% full. Our activeMQ broker shutdown, throwing: Failed to remove consumer: ID:localhost-34991-1349123928205-0:1:74:2201. Reason: org.apache.activemq.broker.BrokerStoppedException: Broker has been stopped: org.apache.active

Re: Maintenance Mode

2012-10-02 Thread Christian Posta
Well, I was suggesting to do it using a JMX console, like "jconsole" that comes with the jvm. But, to do programmatically, I don't think there is a C++ API for JMX. On Tue, Oct 2, 2012 at 11:34 AM, zackhasit wrote: > Excellent! Btw can I do the JMX changes as suggested below via c/c++ or it > ha

Re: Maintenance Mode

2012-10-02 Thread Christian Posta
Yes, if you're trying to sequentially produce to the list of destinations, and a producer blocks because the dest it's trying to write to is full, your whole processing will block. On the other hand, you can set options to not block the producer and instead send an exception if the destination is f

Re: How to program composite queue by using its name?

2012-10-02 Thread exto
With the setup you posted, looks like ActiveMQ would need to be restarted each time we configure a composite destination. Does camel/activemq component support using composite destinations within the camel endpoint uri similar to the following syntax: http://activemq.apache.org/composite-destinati

Re: Maintenance Mode

2012-10-02 Thread Gary Tully
hmm, we don't have a good story for that use case atm. But the memory limit on a destination would be one way to stop message production. Via jmx, you could reduce the memoryLimit, say to 1, on a specific queue and the next message send would block waiting for space. Via jmx it is possible see t

Maintenance Mode

2012-10-02 Thread zackhasit
Hi, I want to bring down consumers connected to a specific queue for maintenance via following steps: 1. Block a particular queue from receiving more messages from producers. (How ?) 2. Check via Console / programatically that all pending messages have been processed by consumers. 3. Now stop

Re: How to find queues and their lengths on activemq

2012-10-02 Thread Gary Tully
http://activemq.apache.org/statisticsplugin.html On 2 October 2012 12:15, Sri wrote: > Hi, > > I am new to active mq and I wanted to find out the queues that are present > on the activemq (not through admin UI )and their respective lengths > programatically as I want to show them in seperate inte

How to find queues and their lengths on activemq

2012-10-02 Thread Sri
Hi, I am new to active mq and I wanted to find out the queues that are present on the activemq (not through admin UI )and their respective lengths programatically as I want to show them in seperate internal status page . is there any way that I can do that? Regards Sri -- View this message

Re: How to program composite queue by using its name?

2012-10-02 Thread Gary Tully
note the xml configuration for that test, the destination mapping is defined in there as it uses the virtual destination feature. see: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/resources/org/apache/activemq/broker/virtual/composite-queue.xml?view=co&revision=916937&content