in spring-jdbc/src/main/java/org/apache/camel/example/spring/jdbc/SpringJdbcRoute.java [30:60]
public void configure() throws Exception {
rest()
.post("/horses")
.to("direct:persist")
.get("/horses")
.to("direct:read");
from("direct:persist")
.choice().when(simple("${header.fail} == 'true'"))
.to("direct:rollback")
.otherwise()
.to("direct:commit");
from("direct:commit")
.setBody(simple(INSERT_QUERY))
.transacted()
.to("spring-jdbc:default?resetAutoCommit=false")
.setBody(constant("executed"));
from("direct:rollback")
.setBody(simple(INSERT_QUERY))
.transacted()
.to("spring-jdbc:default?resetAutoCommit=false")
.rollback("forced to rollback");
from("direct:read")
.setBody(simple(SELECT_QUERY))
.to("spring-jdbc:default");
}