60.12. 트랜잭션 지원

Camel CDI는 일반적으로 지원되는 Camel Cryostated Policy 를 CDI 빈으로 구현하는 방법을 제공합니다. 이러한 정책은 트랜잭션된 EIP를 사용하여 이름으로 조회할 수 있습니다. 예를 들면 다음과 같습니다.

class MyRouteBean extends RouteBuilder {

    @Override
    public void configure() {
        from("activemq:queue:foo")
            .transacted("PROPAGATION_REQUIRED")
            .bean("transformer")
            .to("jpa:my.application.entity.Bar")
            .log("${body.id} inserted");
    }
}

이는 다음과 같습니다.

class MyRouteBean extends RouteBuilder {

    @Inject
    @Named("PROPAGATION_REQUIRED")
    Policy required;

    @Override
    public void configure() {
        from("activemq:queue:foo")
            .policy(required)
            .bean("transformer")
            .to("jpa:my.application.entity.Bar")
            .log("${body.id} inserted");
    }
}

지원되는 트랜잭션 정책 이름 목록은 다음과 같습니다.

Camel CDI는 재전송 오류 처리기를 확장하는 트랜잭션 오류 처리기를 제공하여 예외가 발생할 때마다 롤백을 강제 수행하고 각 재전송에 대해 새 트랜잭션을 생성합니다.

Camel CDI는 구성에 빠르게 액세스할 수 있도록 transactionErrorHandler 도우미 메서드를 노출하는 CdiRouteBuilder 클래스를 제공합니다. 예를 들면 다음과 같습니다.

class MyRouteBean extends CdiRouteBuilder {

    @Override
    public void configure() {
        errorHandler(transactionErrorHandler()
            .setTransactionPolicy("PROPAGATION_SUPPORTS")
            .maximumRedeliveries(5)
            .maximumRedeliveryDelay(5000)
            .collisionAvoidancePercent(10)
            .backOffMultiplier(1.5));
    }
}