You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@camel.apache.org by Alessandro Hoss <al...@gmail.com> on 2019/11/13 14:09:47 UTC
How to get route Exception in a processor with camel+rabbitmq
Hello guys,
I've a route with onException, which sends the message to rabbitMQ, and
another route listening rabbit to call a processor and get the exception
thrown. I'm able to reach this processor, but i'm not able to get the
exception thrown.
I've tried with the <handled> property set to false, and with
transferException=true query param on the endpoint uri's, but without luck.
On the "processorToGetExceptionData" i have tried both
"exchange.getException()" and
"exchange.getProperty(Exchange.EXCEPTION_CAUGHT, Exception.class)", again
without luck.
Above are the (simplified) routes definitions:
<route id="route1">
<from uri="rabbitmq:myExchange?queue=start&routingKey=start"/>
<onException>
<exception>java.lang.Exception</exception>
<redeliveryPolicy maximumRedeliveries="2"
redeliveryDelay="5000" retryAttemptedLogLevel="WARN"/>
<handled>
<constant>true</constant>
</handled>
<setHeader headerName="rabbitmq.ROUTING_KEY">
<constant>errorMessage</constant>
</setHeader>
<to uri="rabbitmq:myExchange?skipQueueDeclare=true"/>
</onException>
<process ref="processorThatThrowsSomeException"/>
<to uri="anyEndpoint" />
</route>
<route id="route2">
<from
uri="rabbitmq:myExchange?queue=errorMessage&routingKey=errorMessage"/>
<process ref="processorToGetExceptionData"/>
<to uri="anotherEndpoint"/>
</route>
Any ideas on what could be wrong ?
Thanks in advance,
Alessandro Hoss
Re: How to get route Exception in a processor with camel+rabbitmq
Posted by Alessandro Hoss <al...@gmail.com>.
In ActiveMQ component there is a "transferExchange" URI parameter, which
makes possible to get the exception after sending it to another queue
through activemq.
Is there a way of doing this (transfer the exchange over the messaging
layer) with RabbitMQ?
Em qua., 13 de nov. de 2019 às 17:45, Alessandro Hoss <al...@gmail.com>
escreveu:
> Hi ..
>
> "myExchange" is not the queue name... When working with rabbitmq, you
> always send the message to a "RabbitMQ Exchange", which redirects it to
> some queue based on the routingKey (which is defined on the creation of the
> queue)... quite complex, but RabbitMQ component has different concepts than
> JMS and AMQP components.
>
> In this case, the <from> in route1 is consuming from the "start" queue,
> and the <to> inside <onException> is sending to "errorMessage" queue (by
> the rabbitmq.ROUTING_KEY header), which is consumed by route2.
>
> The flow is working fine, the only problem is that I can't get the
> Exception "CAUGHT" nor "HANDLED" in route1, by the processor in route2.
>
>
> Em qua., 13 de nov. de 2019 às 16:55, WEIQUAN YUAN <we...@gmail.com>
> escreveu:
>
>> why your from queue name is same as to queue name?
>>
>> On Wed, Nov 13, 2019 at 9:10 AM Alessandro Hoss <al...@gmail.com>
>> wrote:
>>
>> > Hello guys,
>> >
>> > I've a route with onException, which sends the message to rabbitMQ, and
>> > another route listening rabbit to call a processor and get the exception
>> > thrown. I'm able to reach this processor, but i'm not able to get the
>> > exception thrown.
>> >
>> > I've tried with the <handled> property set to false, and with
>> > transferException=true query param on the endpoint uri's, but without
>> luck.
>> >
>> > On the "processorToGetExceptionData" i have tried both
>> > "exchange.getException()" and
>> > "exchange.getProperty(Exchange.EXCEPTION_CAUGHT, Exception.class)",
>> again
>> > without luck.
>> >
>> > Above are the (simplified) routes definitions:
>> >
>> > <route id="route1">
>> > <from uri="rabbitmq:myExchange?queue=start&routingKey=start"/>
>> > <onException>
>> > <exception>java.lang.Exception</exception>
>> > <redeliveryPolicy maximumRedeliveries="2"
>> > redeliveryDelay="5000" retryAttemptedLogLevel="WARN"/>
>> > <handled>
>> > <constant>true</constant>
>> > </handled>
>> > <setHeader headerName="rabbitmq.ROUTING_KEY">
>> > <constant>errorMessage</constant>
>> > </setHeader>
>> > <to uri="rabbitmq:myExchange?skipQueueDeclare=true"/>
>> > </onException>
>> > <process ref="processorThatThrowsSomeException"/>
>> > <to uri="anyEndpoint" />
>> > </route>
>> >
>> > <route id="route2">
>> > <from
>> >
>> uri="rabbitmq:myExchange?queue=errorMessage&routingKey=errorMessage"/>
>> > <process ref="processorToGetExceptionData"/>
>> > <to uri="anotherEndpoint"/>
>> > </route>
>> >
>> > Any ideas on what could be wrong ?
>> >
>> > Thanks in advance,
>> > Alessandro Hoss
>> >
>>
>>
>> --
>> ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
>> Weiquan Yuan
>> Located in Ottawa, Canada
>>
>
>
> --
> Alessandro Hoss
>
--
Alessandro Hoss
Re: How to get route Exception in a processor with camel+rabbitmq
Posted by Alessandro Hoss <al...@gmail.com>.
Hi ..
"myExchange" is not the queue name... When working with rabbitmq, you
always send the message to a "RabbitMQ Exchange", which redirects it to
some queue based on the routingKey (which is defined on the creation of the
queue)... quite complex, but RabbitMQ component has different concepts than
JMS and AMQP components.
In this case, the <from> in route1 is consuming from the "start" queue, and
the <to> inside <onException> is sending to "errorMessage" queue (by the
rabbitmq.ROUTING_KEY header), which is consumed by route2.
The flow is working fine, the only problem is that I can't get the
Exception "CAUGHT" nor "HANDLED" in route1, by the processor in route2.
Em qua., 13 de nov. de 2019 às 16:55, WEIQUAN YUAN <we...@gmail.com>
escreveu:
> why your from queue name is same as to queue name?
>
> On Wed, Nov 13, 2019 at 9:10 AM Alessandro Hoss <al...@gmail.com> wrote:
>
> > Hello guys,
> >
> > I've a route with onException, which sends the message to rabbitMQ, and
> > another route listening rabbit to call a processor and get the exception
> > thrown. I'm able to reach this processor, but i'm not able to get the
> > exception thrown.
> >
> > I've tried with the <handled> property set to false, and with
> > transferException=true query param on the endpoint uri's, but without
> luck.
> >
> > On the "processorToGetExceptionData" i have tried both
> > "exchange.getException()" and
> > "exchange.getProperty(Exchange.EXCEPTION_CAUGHT, Exception.class)", again
> > without luck.
> >
> > Above are the (simplified) routes definitions:
> >
> > <route id="route1">
> > <from uri="rabbitmq:myExchange?queue=start&routingKey=start"/>
> > <onException>
> > <exception>java.lang.Exception</exception>
> > <redeliveryPolicy maximumRedeliveries="2"
> > redeliveryDelay="5000" retryAttemptedLogLevel="WARN"/>
> > <handled>
> > <constant>true</constant>
> > </handled>
> > <setHeader headerName="rabbitmq.ROUTING_KEY">
> > <constant>errorMessage</constant>
> > </setHeader>
> > <to uri="rabbitmq:myExchange?skipQueueDeclare=true"/>
> > </onException>
> > <process ref="processorThatThrowsSomeException"/>
> > <to uri="anyEndpoint" />
> > </route>
> >
> > <route id="route2">
> > <from
> >
> uri="rabbitmq:myExchange?queue=errorMessage&routingKey=errorMessage"/>
> > <process ref="processorToGetExceptionData"/>
> > <to uri="anotherEndpoint"/>
> > </route>
> >
> > Any ideas on what could be wrong ?
> >
> > Thanks in advance,
> > Alessandro Hoss
> >
>
>
> --
> ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
> Weiquan Yuan
> Located in Ottawa, Canada
>
--
Alessandro Hoss
Re: How to get route Exception in a processor with camel+rabbitmq
Posted by WEIQUAN YUAN <we...@gmail.com>.
why your from queue name is same as to queue name?
On Wed, Nov 13, 2019 at 9:10 AM Alessandro Hoss <al...@gmail.com> wrote:
> Hello guys,
>
> I've a route with onException, which sends the message to rabbitMQ, and
> another route listening rabbit to call a processor and get the exception
> thrown. I'm able to reach this processor, but i'm not able to get the
> exception thrown.
>
> I've tried with the <handled> property set to false, and with
> transferException=true query param on the endpoint uri's, but without luck.
>
> On the "processorToGetExceptionData" i have tried both
> "exchange.getException()" and
> "exchange.getProperty(Exchange.EXCEPTION_CAUGHT, Exception.class)", again
> without luck.
>
> Above are the (simplified) routes definitions:
>
> <route id="route1">
> <from uri="rabbitmq:myExchange?queue=start&routingKey=start"/>
> <onException>
> <exception>java.lang.Exception</exception>
> <redeliveryPolicy maximumRedeliveries="2"
> redeliveryDelay="5000" retryAttemptedLogLevel="WARN"/>
> <handled>
> <constant>true</constant>
> </handled>
> <setHeader headerName="rabbitmq.ROUTING_KEY">
> <constant>errorMessage</constant>
> </setHeader>
> <to uri="rabbitmq:myExchange?skipQueueDeclare=true"/>
> </onException>
> <process ref="processorThatThrowsSomeException"/>
> <to uri="anyEndpoint" />
> </route>
>
> <route id="route2">
> <from
> uri="rabbitmq:myExchange?queue=errorMessage&routingKey=errorMessage"/>
> <process ref="processorToGetExceptionData"/>
> <to uri="anotherEndpoint"/>
> </route>
>
> Any ideas on what could be wrong ?
>
> Thanks in advance,
> Alessandro Hoss
>
--
~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
Weiquan Yuan
Located in Ottawa, Canada