[원문출처] http://camel.apache.org/error-handler.html
해당 문서의 경우 Apache 재단의 Camel Document 문서 일부를 번역 한 것입니다.
번역본인 해당 문서의 경우 역자에게 있음을 알리며 상업적 이용을 불허합니다.
www.sogomsoft.co.kr (주) 소곰소프트
에러 핸들러(Error Handler)
Camel은 이벤트 기반 Consumer가 에러 처리하는 것을 다루기 위해 플러그인 가능한 ErrorHandler 전략들을 제공한다. 예외 절(Exception Clause)를 사용하여 DSL에서 직접 에러 핸들링을 지정하는 것은 선택적이다.
소개와 배경 지식를 위해 Error handling in Camel 을 보라.
현재 Camle 구현체들이 다음 특별한 기능을 제공한다. :
비 트랜잭션 (Non transacted : 트랜잭션을 지원하지 않는)
- DefaultErrorHandler 는 Camel 에서 기본 에러 핸들러이다. 이 에러 핸들러는 데드 레터 큐(dead letter queue)를 지원하지 않고 호출한 곳에 exception을 전달하게 될 것이다. 만약 전혀 에러 핸들러가 없다면 Features의 설정에 제한을 가진다.
- Dead Letter Channel 는 데드 레터 엔드포인트에 보내기 전에 메시지 교환의 횟수를 재 전송하기 위해 시도하는 것을 지원한다.
- LoggingErrorHandler는 단지 Exception을 잡아내고 로깅하기 위한 것이다.
- NoErrorHandler 는 어떠한 에러 핸들링도 없는 것이다.
트랜잭션 (Transacted : 트랜잭션을 지원하는)
에러 핸들러들은 다음 예에서 보여주는 것처럼 DSL에서 룰 전체 또는 특정 라우팅 룰에 지원 될 수 있다. 에러 핸들러 룰들은 단일 RouteBuilder 안에서 각각 라우팅하는 룰 위에 상속 된다.
제공되는 에러 핸들러의 간단한 요약
DefaultErrorHandler 는 Camel 에서 기본에러 핸들러이다. Dead Letter Channel 와 다르게 어떠한 데드 레터 큐(dead letter queue)를 가지고 있지 않다. 그리고 기본적으로 Exception들을 핸들링 하지 않는다.
Dead Letter Channel은 1초 딜레이를 사용하여 최대 6번의 재 전송을 할 것이다. 만약 exchange가 실패 하면 ERROR 레벨에 로깅 될 것이다.
사용하기 위해 기본 데드 레터 엔드포인트를 환경 설정 할 수 있다. :
RouteBuilder builder = new RouteBuilder() {
public void configure() {
errorHandler(deadLetterChannel("seda:errors"));
from("seda:a").to("seda:b");
}
};
|
또는 in Spring DSL 에서
<bean id="deadLetterErrorHandler" class="org.apache.camel.builder.DeadLetterChannelBuilder">
<property name="deadLetterUri" value="log:dead"/>
</bean>
...
</camelContext>
|
또는 Camel 2.3.0 이후 부터 또한
<camel:errorHandler id="deadLetterErrorHandler" type="DeadLetterChannel" deadLetterUri="log:dead">
<camel:camelContext errorHandlerRef="deadLetterErrorHandler">
...
</camel:camelContext>
|
Logging Error Handler
로깅 에러 핸들러는 캐치되지 않은 Exception이 던져 질 때 마다 기본적으로 ERROR 레벨에 로깅 될 것이다. 로깅 카테고리, 로거, 레벨은 빌더에서 모두 정의 될 수 있다.
errorHandler(loggingErrorHandler("mylogger.name").level(LoggingLevel.INFO));
|
또는 Spring DSL 에서
<bean id="loggingErrorHandler" class="org.apache.camel.builder.LoggingErrorHandler">
<property name="logName" value="mylogger.name"/>
<property name="level" value="DEBUG"/>
</bean>
...
</camelContext>
|
또는 Camel 2.3.0 이후 부터 또한
<camel:errorHandler id="loggingErrorHandler" type="LoggingErrorHandler" logName="mylogger.name" level="DEBUG"/>
<camel:camelContext errorHandlerRef="loggingErrorHandler">
...
</camel:camelContext>
|
이것은 카테고리는 mylogger.name 을 사용하여 에러 핸들러를 생성하게 되고 그리고 모든 로그 메시지를 생성하기 위해 INFO 레벨을 사용한다.
from("seda:a").errorHandler(loggingErrorHandler("mylogger.name").level(LoggingLevel.DEBUG)).to("seda:b");
|
또 로거는 특정 라우터를 위해서 정의 될 수 있다. may also be defined for specific routes.
No Error Handler
no error handler는 에러 핸들링을 비활성화 하기 위해 사용된다.
errorHandler(noErrorHandler());
|
또는 Spring DSL에서
<bean id="noErrorHandler" class="org.apache.camel.builder.NoErrorHandlerBuilder"/>
...
</camelContext>
|
또는 Camel 2.3.0 이후 부터 또한
<camel:errorHandler id="noErrorHandler" type="NoErrorHandler"/>
<camel:camelContext errorHandlerRef="noErrorHandler">
...
</camel:camelContext>
|
TransactionErrorHandler는 Camel에서 트랜잭션이 적용된 라우터를 위한 기본 에러 헨들러이다.
Error Handler(들)에 의해 지원되는 기능이 여기 있다. :
Feature | 다음 Error Handler에 의해 지원 |
|---|
all scopes | DefaultErrorHandler, TransactionErrorHandler, Dead Letter Channel |
onException | DefaultErrorHandler, TransactionErrorHandler, Dead Letter Channel |
onWhen | DefaultErrorHandler, TransactionErrorHandler, Dead Letter Channel |
continued | DefaultErrorHandler, TransactionErrorHandler, Dead Letter Channel |
handled | DefaultErrorHandler, TransactionErrorHandler, Dead Letter Channel |
Custom ExceptionPolicy | DefaultErrorHandler, TransactionErrorHandler, Dead Letter Channel |
useOriginalBody | DefaultErrorHandler, TransactionErrorHandler, Dead Letter Channel |
retryWhile | DefaultErrorHandler, TransactionErrorHandler, Dead Letter Channel |
onRedelivery | DefaultErrorHandler, TransactionErrorHandler, Dead Letter Channel |
RedeliveryPolicy | DefaultErrorHandler, TransactionErrorHandler, Dead Letter Channel |
asyncDelayedRedelivery | DefaultErrorHandler, TransactionErrorHandler, Dead Letter Channel |
redeliverWhileStopping | DefaultErrorHandler, TransactionErrorHandler, Dead Letter Channel |
dead letter queue | Dead Letter Channel |
| onPrepareFailure | DefaultErrorHandler, Dead Letter Channel |
위 기능들의 일부의 문서는 Exception 절(Exception Clause) 문서를 보라.
Scopes
에러 핸들러의 스코프는 다음 중 하나 이다.
다음 예는 어떻게 글로벌 에러 핸들러를 등록하는지를 보여준다. (이 경우에서는 logging handler를 사용한다.)
RouteBuilder builder = new RouteBuilder() {
public void configure() {
errorHandler(loggingErrorHandler("com.mycompany.foo"));
from("seda:a").to("seda:b");
}
};
|
다음 예는 어떻게 라우터에 특정 에러 핸들러를 등록할 수 있는지를 보여 준다. 커스터마이징 된 로그 핸들러는 단지 Endpoint seda:a로 부터 라우터를 위해서 등록된다.
RouteBuilder builder = new RouteBuilder() {
public void configure() {
from("seda:a")
.errorHandler(loggingErrorHandler("com.mycompany.foo"))
.to("seda:b");
from("seda:b").to("seda:c");
}
};
|
Spring 기반의 환경 구성
에러 핸들러는 스프링 빈과 다음 스코프 에서 처럼 환경 구성 될 수 있다. :
- global (camelContext 테그)
- route 당 (route 테그)
- policy 당 (policy/transacted 테그)
에러 핸들러는 errorHandlerRef 속성으로 환경 구성 될 수 있다.
Spring 기반 환경 구성 예제
이 예에서 라우터에서 최종 3번과 재시도 전에 약간의 딜레이로 재전송하는 라우터에서 Dead Letter Channel 을 환경 구성한다.
먼저 route 테그에서 errorHandlerRef 속성을 사용하여 myDeadLetterErrorHandler 에 참조를 환경 설정한다..
<template id="myTemplate"/>
errorHandlerRef 를 설정, 단지 이 라우터를 위해서만 적용된다. --> <route errorHandlerRef="myDeadLetterErrorHandler">
<from uri="direct:in"/>
<process ref="myFailureProcessor"/>
<to uri="mock:result"/>
</route>
</camelContext>
|
그리고 Dead Letter Channel인 스프링 bean 엘리먼트를 사용하여 표준 스프링으로 myDeadLetterErrorHandler를 환경 구성한다.
그리고 마지막으로 얼마나 많이 재전송할 것인지 지연시킬 것인지 등을 위한 옵션을 환경 구성할 재전송 정책을 위한 다른 Spring 빈을 가진다.
<bean id="myDeadLetterErrorHandler" class="org.apache.camel.builder.DeadLetterChannelBuilder">
<property name="deadLetterUri" value="mock:dead"/>
<property name="redeliveryPolicy" ref="myRedeliveryPolicyConfig"/>
</bean>
<bean id="myRedeliveryPolicyConfig" class="org.apache.camel.processor.RedeliveryPolicy">
<property name="maximumRedeliveries" value="3"/>
<property name="redeliveryDelay" value="250"/>
</bean>
|
Camel 2.3.0 부터, Camel은 에러 핸들러를 위하여 customer 빈 환경 구성을 제공한다. 여기 예제가 있다.
<errorHandler id="loggingErrorHandler" type="LoggingErrorHandler" logName="foo" level="INFO"
redeliveryPolicy )을 정의 할 수 있다. --> <camel:errorHandler id="defaultErrorHandler" type="DefaultErrorHandler">
<camel:redeliveryPolicy maximumRedeliveries="2" redeliveryDelay="0" logStackTrace="false"/>
</camel:errorHandler>
<camel:errorHandler id="deadLetterErrorHandler" type="DeadLetterChannel" deadLetterUri="log:dead">
<camel:redeliveryPolicy maximumRedeliveries="2"
redeliveryDelay="1000"
logHandled="true"
asyncDelayedRedelivery="true"/>
</camel:errorHandler>
<bean id="myErrorProcessor" class="org.apache.camel.spring.handler.MyErrorProcessor"/>
<camel:errorHandler id="transactionErrorHandler" type="TransactionErrorHandler"
transactionTemplateRef="PROPAGATION_REQUIRED" onRedeliveryRef="myErrorProcessor"/>
<camel:errorHandler id="txEH" type="TransactionErrorHandler" transactionManagerRef="txManager"/>
<errorHandler id="noErrorHandler" type="NoErrorHandler"/>
</camelContext>
|
트랜잭션을 지원하는(transactional) 에러 핸들러 사용
트랜잭션 에러 핸들러는 스프링 트랜잭션을 기반으로 되어 있고 camel-spring component의 사용을 필요로 한다..
사용하는 방법과 에러 핸들러로 환경 구성하는 트랜잭션 행위와 환경 구성을 위한 많은 예가 있는 Transactional Client를 보라.
See also