Message creation / sending hanging for ActiveMQ Topic

[rcasazza]

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

[rcasazza]

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.