Gary:
We already have code on the client site(where connection is initiated) to
handle the exception. But the same message also showed up on server log and
we would like to filter it out.
Our AMQ broker is configured and started via spring
bean(org.apache.activemq.xbean.BrokerFactoryBean). Is th
Did you figure out the fix?
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Message-Group-Concurrent-Consumers-Issue-tp2367512p3466386.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Thanks Thomas.
I was having a durable consumer subscribed to this topic, but after the
consumer id done, I have deleted the subscriber from the Manage broker
activemq page.
In another setup, I have closed the consumer and deleted it, as,
consumer.Close();
session.DeleteDurableConsumer("test");
HI,
How can I create a non durable/persistent topic. I want my topic to discard
messages after a certain limit.
Even if a durable consumer tried to subscribe on this topic, the topic
itself should not allow it.
How this type of scenario is achievable.
Thanks,
Manu
--
View this message in conte
Is your consumer setup to be a durable subscriber by any chance?
Before: Your broker received a message for the topic, it has no subscribers for
it so throws the message away.
Now: Your broker receives a message for the topic, it knows that it has a
subscriber who wants to be sent the messages wh
2011-04-21 15:03:59,134 | ERROR | Failed to start ActiveMQ JMS Message
Broker. Reason: java.io.IOException: Detected missing/corrupt journal files.
73 messages affected. | org.apache.activemq.broker.BrokerService | main
java.io.IOException: Detected missing/corrupt journal files. 73 messages
affect
Hi,
for my MessageDrivenBean inside of a JBoss6 I'm using the activemq resource
adapter. At runtime i need to change the adapters ra.xml. JBoss is smart
enough to redeploy the adapter when this happens, but the mdb looses the
connection to the broker and doesn't get a new one.
Instead my log is
Same issue, except I'm using ActiveMQ 5.5. And even with
consumer.prefetchSize=1, I still have messages for all group IDs being sent
to consumers on only one of the JVMs.
Even more intriguing, if I let the whole thing run for a longish period, I
*do* see some or all of the message groups switchin
