[Camel in Action] 2-4. Content-Based Router와 Message Filter EIP 구현

Table of Contents

Enterprise Integration Patterns (EIP)

Gregor Hohpe와 Bobby Woolf가 정의한 엔터프라이즈 통합 패턴(EIP)은 메시지 기반 통합의 모범 사례들을 패턴으로 정리한 것입니다. Apache Camel은 이 패턴들을 직접 구현합니다. 이번 글에서는 가장 자주 사용되는 두 패턴을 살펴봅니다.

Content-Based Router (CBR) – 내용 기반 라우터

메시지의 내용이나 헤더 값에 따라 다른 목적지로 전달하는 패턴입니다. Camel에서는 choice()로 구현합니다.

from("direct:orderInput")
    .choice()
        .when(simple("${body.orderType} == 'VIP'"))
            .log("VIP 주문: ${body.customerId}")
            .to("direct:vipOrderProcess")
        .when(simple("${body.amount} > 1000000"))
            .log("대용량 주문")
            .to("direct:largeOrderProcess")
        .when(header("region").isEqualTo("OVERSEAS"))
            .to("direct:overseasOrderProcess")
        .otherwise()
            .to("direct:normalOrderProcess")
    .end()
    .log("라우팅 완료");

다양한 조건 표현 방법

// Simple 언어
.when(simple("${header.status} == 'APPROVED'"))

// XPath (XML 메시지)
.when(xpath("/order/status = 'approved'"))

// JSONPath (JSON 메시지)
.when(jsonpath("$.order.status == 'approved'"))

// Java Predicate
.when(exchange -> exchange.getIn().getHeader("amount", Integer.class) > 50000)

// SpEL
.when(spel("#{request.headers['priority'] == 'HIGH'"}))

// 정규식
.when(simple("${body} regex '.*URGENT.*'"))

Message Filter – 메시지 필터

조건을 만족하지 않는 메시지를 완전히 걸러내는 패턴입니다. filter()로 구현합니다.

from("jms:queue:allOrders")
    .filter(simple("${body.amount} >= 10000"))  // 1만원 이상만 처리
        .log("처리 대상 주문: ${body.orderId}")
        .to("direct:processOrder");
// 조건 불만족 메시지는 조용히 버려짐

// 복잡한 필터 조건
from("direct:events")
    .filter(exchange -> {
        String type = exchange.getIn().getHeader("eventType", String.class);
        int priority = exchange.getIn().getHeader("priority", 0, Integer.class);
        return "ORDER".equals(type) && priority > 5;
    })
    .to("direct:highPriorityOrders");

Wiretap – 메시지 복사 감청

원본 흐름을 방해하지 않고 메시지를 다른 경로로 복사해 보내는 패턴입니다. 감사 로그, 모니터링에 유용합니다.

from("direct:orders")
    .wireTap("direct:auditLog")  // 비동기로 감사 로그에 복사
    .to("direct:processOrder");  // 원본 흐름은 계속 진행

from("direct:auditLog")
    .log("감사: ${date:now:yyyy-MM-dd HH:mm:ss} - 주문 ${body.orderId}")
    .to("jms:queue:audit");

Multicast – 동일 메시지를 여러 곳으로

하나의 메시지를 여러 엔드포인트에 동시에 전달합니다.

from("direct:newOrder")
    .multicast()
        .parallelProcessing()
        .to("direct:inventory", "direct:billing", "direct:notification")
    .end()
    .log("모든 처리 완료");