[Camel in Action] 11-1. Camel 에러 핸들링 완전 정복 – onException과 DeadLetterChannel

Table of Contents

Camel에서 에러 핸들링이 중요한 이유

외부 시스템과 연동하는 통합 애플리케이션에서 에러는 예외가 아니라 일상입니다. 네트워크 장애, 외부 API 다운, 잘못된 데이터 형식 등 다양한 이유로 처리 중 예외가 발생합니다. Camel은 이런 상황을 체계적으로 처리하기 위한 강력한 에러 핸들링 메커니즘을 제공합니다.

기본 에러 전파 방식

Camel 라우트에서 예외가 발생하면 기본적으로 호출자에게 예외가 전파됩니다. Consumer(소비자)에서 발생한 경우 예외 처리 방식은 컴포넌트마다 다릅니다.

JMS: 메시지가 롤백되어 재시도 큐로 이동
File: 파일을 moveFailed 디렉터리로 이동
HTTP: 에러 응답 코드 반환

onException으로 특정 예외 처리

특정 예외 타입에 따라 다른 처리를 하려면 onException을 사용합니다. RouteBuilder의 configure() 메서드 상단에 선언합니다.

public class OrderRoutes extends RouteBuilder {
  @Override
  public void configure() throws Exception {

    // 유효성 검사 실패: 에러 응답 반환
    onException(ValidationException.class)
      .handled(true)
      .setHeader(Exchange.HTTP_RESPONSE_CODE, constant(400))
      .setBody(simple("잘못된 요청: ${exception.message}"));

    // 외부 서비스 연결 실패: 3번 재시도 후 DLQ로
    onException(ConnectException.class)
      .maximumRedeliveries(3)
      .redeliveryDelay(2000)
      .backOffMultiplier(2) // 지수 백오프: 2초, 4초, 8초
      .useExponentialBackOff()
      .to("activemq:queue:failed-orders");

    from("direct:processOrder")
      .to("bean:orderService");
  }
}

handled(true)는 예외를 소비해서 더 이상 전파되지 않게 합니다. 없으면 처리 후에도 예외가 계속 위로 전파됩니다.

Dead Letter Channel – 실패 메시지 격리

Dead Letter Channel은 처리 실패 메시지를 특정 엔드포인트(Dead Letter Queue)로 보내는 에러 핸들러입니다.

errorHandler(deadLetterChannel("activemq:queue:DLQ")
  .maximumRedeliveries(3)
  .redeliveryDelay(1000)
  .retryAttemptedLogLevel(LoggingLevel.WARN)
  .logStackTrace(true));

DLQ를 모니터링하면 처리 실패 메시지를 나중에 수동으로 재처리하거나 원인을 분석할 수 있습니다.

Retry와 지수 백오프 전략

일시적인 장애에는 즉시 재시도보다 점진적으로 간격을 늘리는 지수 백오프가 효과적입니다. 상대방 서버에 부하를 주지 않으면서 복구 시간을 줍니다.

onException(IOException.class)
  .maximumRedeliveries(5)
  .redeliveryDelay(1000)       // 첫 재시도: 1초 후
  .backOffMultiplier(2.0)       // 다음: 2초, 4초, 8초, 16초
  .useExponentialBackOff()
  .maximumRedeliveryDelay(60000) // 최대 60초 간격
  .logRetryAttempted(true);

예외 정보 활용

예외 처리 중에 예외 정보를 메시지에 담아 DLQ나 알림으로 보낼 수 있습니다.

onException(Exception.class)
  .handled(true)
  .process(exchange -> {
    Exception cause = exchange.getProperty(Exchange.EXCEPTION_CAUGHT, Exception.class);
    exchange.getIn().setHeader("errorMessage", cause.getMessage());
    exchange.getIn().setHeader("errorClass", cause.getClass().getName());
  })
  .to("activemq:queue:error-notifications");

zerg96