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
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
@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:
>
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
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
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
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
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
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
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
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
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
12 matches
Mail list logo