Hi all,
I'm able to redirect simple files to an ActiveMQ Queue with no issues.
However, when I change from a queue to a topic, the message seems to get stuck during creation.. I see the Camel lock on the file and the following:
org.apache.camel.component.jms.JmsConfiguration$CamelJmsTemplate:572 - Sending created message: ActiveMQBytesMessage {commandId = 0, respon...
I see the topic created in the ActiveMQ console when I execute but no messages.
The route is easy, namely
public void configure() throws Exception {
from("file:/test/in")
.to("activemq:topic:com.changes2");
But it appears by changing topic to queue is works fine. I'm new to topics so I'm not sure if I'm missing something there.... a parameter?
Thanks
My bad.
Just in case anyone was noodling over this one, I was unaware of the Producer Flow Control that ActiveMQ defaults to for topics.
Once I found this... everything works as expected.