[Camel in Action] 4-3. Camel Bean 파라미터 바인딩과 어노테이션

Table of Contents

파라미터 바인딩이란?

Camel이 Bean 메서드를 호출할 때, Exchange에서 필요한 데이터를 꺼내 메서드 파라미터에 자동으로 바인딩합니다. 이를 파라미터 바인딩(Parameter Binding)이라 합니다.

기본 타입 바인딩

// Camel이 자동으로 처리하는 기본 타입들
public class OrderProcessor {
    // Exchange 전체
    public void process(Exchange exchange) { ... }

    // Message 객체
    public void process(Message message) { ... }

    // 본문 직접 (타입 변환 포함)
    public void process(Order order) { ... }
    public void process(String text) { ... }

    // 여러 파라미터 - Camel이 자동 매핑
    public void process(Order order, Exchange exchange) { ... }
}

Camel 어노테이션으로 정밀 바인딩

import org.apache.camel.Body;
import org.apache.camel.Header;
import org.apache.camel.Headers;
import org.apache.camel.ExchangeProperty;

@Component
public class AnnotatedOrderService {

    // @Body: 메시지 본문 바인딩
    public Order processOrder(@Body Order order) {
        return doProcess(order);
    }

    // @Header: 특정 헤더 바인딩
    public String generateConfirmation(
            @Body Order order,
            @Header("customerId") String customerId,
            @Header(value = "region", defaultValue = "DOMESTIC") String region) {
        return customerId + "-" + order.getId() + "-" + region;
    }

    // @Headers: 전체 헤더 Map 바인딩
    public void logHeaders(@Headers Map<String, Object> headers) {
        headers.forEach((k, v) -> System.out.println(k + " = " + v));
    }

    // @ExchangeProperty: Exchange 프로퍼티 바인딩
    public void process(@Body Order order,
                        @ExchangeProperty("correlationId") String corrId) {
        System.out.println("상관관계 ID: " + corrId);
    }
}

언어 어노테이션

import org.apache.camel.language.Simple;
import org.apache.camel.language.XPath;
import org.apache.camel.language.JsonPath;

@Component
public class ExpressionBean {

    // @Simple: Simple 표현식으로 값 가져오기
    public void process(@Body Order order,
                        @Simple("${date:now:yyyy-MM-dd}") String today) {
        System.out.println("오늘 날짜: " + today);
    }

    // @XPath: XML 메시지에서 XPath로 값 추출
    public void processXml(@XPath("//order/@id") String orderId,
                           @XPath("//order/amount/text()") double amount) {
        System.out.printf("주문 %s: %.2f원%n", orderId, amount);
    }

    // @JsonPath: JSON 메시지에서 JsonPath로 값 추출
    public void processJson(@JsonPath("$.orderId") String orderId,
                            @JsonPath("$.customer.name") String name) {
        System.out.println(orderId + " - " + name);
    }
}

@BeanInject로 의존성 주입

// 라우트 빌더 내에서 Bean 주입
public class MyRoute extends RouteBuilder {
    @BeanInject
    private OrderService orderService;

    @Override
    public void configure() {
        from("direct:start")
            .bean(orderService);
    }
}

Optional 파라미터

// 헤더가 없을 때 null 허용
public void process(@Body Order order,
                    @Header(value="priority", required=false) Integer priority) {
    int p = priority != null ? priority : 0;
    // ...
}

반환값 처리

// void: 본문 변경 없음
public void log(@Body Order order) {
    System.out.println(order);
}

// 값 반환: 반환값이 새로운 메시지 본문이 됨
public Order transform(@Body String json) {
    return parseOrder(json);
}

// null 반환: 본문이 null로 설정됨 (주의)
public Order conditionalTransform(@Body String json) {
    if (!isValid(json)) return null;  // 주의: null로 설정됨
    return parseOrder(json);
}

zerg96