Warning: Disabling JMSReplyTo as this Exchange is not OUT capable

[larsroediger]

Hi,

I use FuseESB 4.1 and Camel for routing JMS messages from a consumer to a provider and back to the consumer. It seems that everything works fine, but when I take a look at the log-file I can find several warnings like

>> Disabling JMSReplyTo as this Exchange is not OUT capable <<

and when I run the JConsole I got

>> Error calling isBroadcaster: org.apache.activemq:BrokerName=localhost ... <<

Here are some extracts of the important parts of the consumer and provider bundles:

-- consumer sending the message to queue A --

...

ActiveMQConnection connection = ActiveMQConnection.makeConnection("tcp://localhost:61616");

connection.start();

Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

Destination destination = session.createQueue("A");

MessageProducer producer = session.createProducer(destination);

TextMessage[] message = new TextMessage[Anz];

session.createTextMessage();

producer.send(message[i]);

...

-- consumer routing the message from queue A to a remote JMS provider --

...

from("activemq:A").to("jms:innos.szenario2.provider");

...

-- provider sending the message back to the consumer --

...

from("jms:innos.szenario2.provider").to("activemq:B");

...

-- consumer receiving the message from queue B --

...

Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

               Destination destination = session.createQueue("B");

               MessageConsumer consumer = session.createConsumer (destination);

message = consumer.receive(id);

...

I think it's about not using the right message exchange pattern (in-only, in-out), isn't it? Do I have to set properties to the Camel-URIs, like disableReplyTo, or am I using the wrong JMS acknowledgment mode.

Thanks for your help.

[davsclaus]

Hi

The JMSReplyTo WARN has been fixed in the next release:

https://issues.apache.org/activemq/browse/CAMEL-1614

You message exchange pattern looks fine to me if you are doing a in only. Eg the original caller do not expect a reply.

Its Camel that got a bit confused about this. The next release should have this WARN log fixed.

How do you connect with JConsole? And can you show how you have configured the Camel/ActiveMQ JMX agent?

[larsroediger]

I use the default ActiveMQ Broker of SMX 4.1 (so by default it is useJmx="true") and refer to the embedded broker using the following bean in the Spring-XML configuration file. This bean refers to the URI "activemq" in the RouteBuilder I mentioned. Similiar bean I configured for the URI "jms". First of all I want to run it all on a local machine. Next step would be to distribute the provider and consumer bundle on two different machines.