Myujth

I have a processor in a camel which is sending message to an endpoint in the camel (apache camel).

I have an endpoint in the camel xml file:

<endpoint id="sendQueue" uri="FBActiveMQ:queue:SEND_Q" />

I made the queue sendQueue deleted from the queuemanager (Using IBM MQ) and I tried to send a message from the processor to this queue and catch an exception and handle it in the processor itself.

The thing is, I never get an exception when the message is sent to the deleted queue.

I am aware that I can have exception handler in the camel file itself but I cannot do so because my processor is doing a transaction inside a transaction boundary and needs to rollback in case of queue failure.

Do you have any clues please?

The code which is written is like this(not the exact code) .

 try
 JmsProducer jmsProducer = new JmsProducer(endPoint);
 jmsProducer.start();
 Exchange exchange = endPoint.createExchange(ExchangePattern.InOnly);
 exchange.getIn().setBody(msg);
 jmsProducer.process(exchange);
 catch(Exception e)
 e.printStackTrace();

 

Have you tried checking the exchange object after the process call in your try block to see if it's got an exception in it.

jmsProducer.process(exchange);
if (exchange.getException() != null) 
 exchange.getException().printStackTrace();;

I think you'll only get an exception thrown if it's something wrong with your jmsProducer (e.g. no camelContext).

... deleted bit about Exchange/Exception typo in original example ...