Hi
- Is the adviced route working (is the expected exception thrown)?
And make sure your transacted-statement in the route follows directly
after the from-statement.
cheers
stefan
On Wed, Apr 25, 2012 at 23:23, javaxmlsoapdev <javaxmlsoap...@yahoo.com> wrote:
> Hello,
>
> I have a use case to pick up a message from source JMS queue and route it to
> bunch of other JMS destination queues. In order to test transaction I have
> followed Camel in Action, steps described in Chapter 9 (Using Transactions),
> with embedded ActiveMQ etc. I have an interceptor like below.
>
> Endpoint sourceQendPoint = sourceQueue.getDefaultEndpoint();
> RouteBuilder rb = new RouteBuilder(){
> public void configure() throws Exception{
>
> interceptSendToEndpoint("activemq:queue:destinationQueue1")
> .throwException(new
> JMSException("Cannot publish to
> destinationQueue1"));
> }
> };
>
> RouteDefinition customRoute = camelContext.getRouteDefinition("route1");
> customRoute.adviceWith((ModelCamelContext)camelContext, rb);
>
> template.sendBody(sourceQendPoint ,"Message changed");
> Thread.sleep(3000);
> //"activemq:queue:ActiveMQ:DLQ"
> Object body =
> consumer.receiveBodyNoWait("activemq:queue:ActiveMQ.DLQ");
> assertNotNull("should not lose message",body);
>
> This assert doesn't work. Dead letter queue is empty as well.
>
> Anything that I may have missed in setting this test case up?
>
> --
> View this message in context:
> http://camel.465427.n5.nabble.com/Transacted-test-case-with-ActiveMQ-not-working-tp5666012p5666012.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
