aldettinger commented on code in PR #165:
URL:
https://github.com/apache/camel-quarkus-examples/pull/165#discussion_r1354520438
##########
message-bridge/src/main/java/org/acme/message/bridge/MessageBridgeRoute.java:
##########
@@ -0,0 +1,46 @@
+package org.acme.message.bridge;
+
+import jakarta.enterprise.context.ApplicationScoped;
+import org.apache.camel.builder.RouteBuilder;
+
+@ApplicationScoped
+public class MessageBridgeRoute extends RouteBuilder {
+
+ @Override
+ public void configure() throws Exception {
+ restConfiguration().component("servlet");
+ rest()
+ .post("/message")
+ .id("rest")
+ .to("direct:publish");
+
+ from("direct:publish")
+ .id("ibmmq")
+ .transacted()
+ .log("Sending message to IBMMQ: ${body}")
+ .to("ibmmq:queue:{{ibm.mq.queue}}?disableReplyTo=true");
+
+ from("ibmmq:queue:{{ibm.mq.queue}}")
+ .id("ibmmq-amq")
+ .transacted()
+ .choice()
+ .when(simple("${header.JMSRedelivered}"))
+ .log("Redelivering message after rollback to ActiveMQ:
${body}")
+ .otherwise()
+ .log("Sending message from IBMMQ to ActiveMQ: ${body}")
+ .end()
+ .to("amq:queue:{{amq.queue}}")
+ .process(ex -> {
+ if
(ex.getIn().getBody(String.class).toLowerCase().contains("rollback")) {
+ if (!ex.getIn().getHeader("JMSRedelivered",
Boolean.class)) {
Review Comment:
The idea might be to rollback the transaction only once. So that we see a
rollback followed by successful commit. Maybe a comment could help readability.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
