public void configure()

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");

    }