Hi Reji,
I've never tested but it remind me about option:
https://camel.apache.org/components/latest/eips/saga-eip.html#_using_custom_identifiers_and_options
hth,
Alex
On Tue, Sep 8, 2020 at 9:48 PM Reji Mathews <contactr...@gmail.com> wrote:
> Hello community
>
> I was wondering if there is a way to retain the exchange data from the
> point of failure in a Saga EIP. Find the following route
> I have simulated an error right after parsing data from the create-order
> api. I need to use the same in compensation flow to undo the order
> creation.
> Logs show that the value of header orderId never trickled down to
> compensation flow.
>
> from("jetty:http://0.0.0.0:8081/testtxn?httpMethodRestrict=GET
> ").streamCaching()
> .log("received http trigger")
>
> .saga().compensation("direct:rollback").propagation(SagaPropagation.REQUIRES_NEW)
> .log("creating fresh order")
> .setBody(constant("{ \"item_code\" : \"XAH504004\",
> \"item_qty\" : 10 }"))
> .setHeader(Exchange.CONTENT_TYPE, constant("application/json"))
> .setHeader(Exchange.HTTP_METHOD, constant("POST"))
> .setHeader(Exchange.HTTP_URI,
> constant("http://localhost:8000/orders";))
> .to("http:dummyhost")
> .log("order api response ${body}")
> .setHeader("orderId", jsonpath("$.businessObject.order_id"))
> .throwException(new Exception("This is a simulated
> error")) // simulating a failure
> .end();
>
> from("direct:rollback")
> .log("saga transaction failed. deleting order ${headers.orderId}")
> .setHeader(Exchange.HTTP_URI,
> simple("http://localhost:8000/orders/${headers.orderId}";))
> .setHeader(Exchange.HTTP_METHOD, constant("DELETE"))
> .to("http:dummyhost")
> .log("compensation call response ${body}")
> .end();
>
>
>
> Logs
>
> ====
>
> 2020-09-08 15:35:55.832 INFO 80448 --- [nio-8000-exec-2]
> o.s.web.servlet.DispatcherServlet : Completed initialization in
> 11 ms
> 2020-09-08 15:35:57.054 INFO 80448 --- [ qtp18025156-26] route1
> : api response
>
> {"message":"success","businessObject":{"order_id":"43657a09-5c32-4303-9b14-73ab03e4e086","item_code":"XAH504004","item_qty":10}}
> 2020-09-08 15:35:57.065 ERROR 80448 --- [ qtp18025156-26]
> o.a.camel.processor.DefaultErrorHandler : Failed delivery for
> (MessageId: ID-5CG7324CR4-1599593718571-0-4 on ExchangeId:
> ID-5CG7324CR4-1599593718571-0-1). Exhausted after delivery attempt: 1
> caught: java.lang.Exception: This is a simulated error
>
> Message History
>
> ---------------------------------------------------------------------------------------------------------------------------------------
> RouteId ProcessorId Processor
> Elapsed (ms)
> [route1 ] [route1 ]
> [jetty:http://0.0.0.0:8081/testtxn?httpMethodRestrict=GET
> ] [ 1373]
> [route1 ] [log1 ] [log
> ] [ 3]
> [route1 ] [output1 ]
> [saga[compensation:direct:rollback,propagation:REQUIRES_NEW]
> ] [ 0]
> [route1 ] [log2 ] [log
> ] [ 0]
> [route1 ] [setBody1 ] [setBody[constant{{
> "item_code" : "XAH504004", "item_qty" : 10 }}] ] [
> 0]
> [route1 ] [setHeader1 ] [setHeader[Content-Type]
> ] [ 0]
> [route1 ] [setHeader2 ] [setHeader[CamelHttpMethod]
> ] [ 0]
> [route1 ] [setHeader3 ] [setHeader[CamelHttpUri]
> ] [ 0]
> [route1 ] [to1 ] [http:dummyhost
> ] [ 1354]
> [route1 ] [log3 ] [log
> ] [ 0]
> [route1 ] [setHeader4 ] [setHeader[orderId]
> ] [ 6]
> [route1 ] [throwException1 ]
> [throwException[java.lang.Exception]
> ] [ 0]
>
> Stacktrace
>
> ---------------------------------------------------------------------------------------------------------------------------------------
>
> java.lang.Exception: This is a simulated error
> at
> com.reji.poc.cluster.camelclustering.routes.SimpleJdbcDBRoute.configure(SimpleJdbcDBRoute.java:32)
> ~[classes/:na]
> at
> org.apache.camel.builder.RouteBuilder.checkInitialized(RouteBuilder.java:465)
> ~[camel-core-2.25.1.jar:2.25.1]
> at
> org.apache.camel.builder.RouteBuilder.configureRoutes(RouteBuilder.java:403)
> ~[camel-core-2.25.1.jar:2.25.1]
> at
> org.apache.camel.builder.RouteBuilder.addRoutesToCamelContext(RouteBuilder.java:384)
> ~[camel-core-2.25.1.jar:2.25.1]
> at
> org.apache.camel.impl.DefaultCamelContext$3.call(DefaultCamelContext.java:1023)
> ~[camel-core-2.25.1.jar:2.25.1]
> at
> org.apache.camel.impl.DefaultCamelContext$3.call(DefaultCamelContext.java:1020)
> ~[camel-core-2.25.1.jar:2.25.1]
> at
> org.apache.camel.impl.DefaultCamelContext.doWithDefinedClassLoader(DefaultCamelContext.java:3266)
> ~[camel-core-2.25.1.jar:2.25.1]
> at
> org.apache.camel.impl.DefaultCamelContext.addRoutes(DefaultCamelContext.java:1020)
> ~[camel-core-2.25.1.jar:2.25.1]
> at
> org.apache.camel.spring.boot.RoutesCollector.onApplicationEvent(RoutesCollector.java:150)
> ~[camel-spring-boot-2.25.1.jar:2.25.1]
> at
> org.apache.camel.spring.boot.RoutesCollector.onApplicationEvent(RoutesCollector.java:57)
> ~[camel-spring-boot-2.25.1.jar:2.25.1]
> at
> org.springframework.context.event.SimpleApplicationEventMulticaster.doInvokeListener(SimpleApplicationEventMulticaster.java:172)
> ~[spring-context-5.1.17.RELEASE.jar:5.1.17.RELEASE]
> at
> org.springframework.context.event.SimpleApplicationEventMulticaster.invokeListener(SimpleApplicationEventMulticaster.java:165)
> ~[spring-context-5.1.17.RELEASE.jar:5.1.17.RELEASE]
> at
> org.springframework.context.event.SimpleApplicationEventMulticaster.multicastEvent(SimpleApplicationEventMulticaster.java:139)
> ~[spring-context-5.1.17.RELEASE.jar:5.1.17.RELEASE]
> at
> org.springframework.context.support.AbstractApplicationContext.publishEvent(AbstractApplicationContext.java:403)
> ~[spring-context-5.1.17.RELEASE.jar:5.1.17.RELEASE]
> at
> org.springframework.context.support.AbstractApplicationContext.publishEvent(AbstractApplicationContext.java:360)
> ~[spring-context-5.1.17.RELEASE.jar:5.1.17.RELEASE]
> at
> org.springframework.context.support.AbstractApplicationContext.finishRefresh(AbstractApplicationContext.java:897)
> ~[spring-context-5.1.17.RELEASE.jar:5.1.17.RELEASE]
> at
> org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.finishRefresh(ServletWebServerApplicationContext.java:162)
> ~[spring-boot-2.1.16.RELEASE.jar:2.1.16.RELEASE]
> at
> org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:553)
> ~[spring-context-5.1.17.RELEASE.jar:5.1.17.RELEASE]
> at
> org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.refresh(ServletWebServerApplicationContext.java:141)
> ~[spring-boot-2.1.16.RELEASE.jar:2.1.16.RELEASE]
> at
> org.springframework.boot.SpringApplication.refresh(SpringApplication.java:744)
> ~[spring-boot-2.1.16.RELEASE.jar:2.1.16.RELEASE]
> at
> org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:391)
> ~[spring-boot-2.1.16.RELEASE.jar:2.1.16.RELEASE]
> at
> org.springframework.boot.SpringApplication.run(SpringApplication.java:312)
> ~[spring-boot-2.1.16.RELEASE.jar:2.1.16.RELEASE]
> at
> org.springframework.boot.SpringApplication.run(SpringApplication.java:1215)
> ~[spring-boot-2.1.16.RELEASE.jar:2.1.16.RELEASE]
> at
> org.springframework.boot.SpringApplication.run(SpringApplication.java:1204)
> ~[spring-boot-2.1.16.RELEASE.jar:2.1.16.RELEASE]
> at
> com.reji.poc.cluster.camelclustering.CamelApplication.main(CamelApplication.java:13)
> ~[classes/:na]
>
> 2020-09-08 15:35:57.084 INFO 80448 --- [hread #1 - saga] route2
> : saga transaction failed. deleting order
>
