Camel의 DynamicRouting

Question

Camel에서 true 또는 false 일 수있는 플래그에서 메시지의 끝점을 선택하는 메커니즘을 연구 중입니다. 이것은 업스트림 채널이 대량으로 침수당하는 경우 대량 인제 스트 엔드 (HDFS로 전송)로 메시지를 다시 라우팅하는 조절 메커니즘입니다.

는 궁극적으로, 내 경로는 다음과 같습니다

from("queue:myqueue").bean("messageParser") 
    .dynamicRoute(bean(ThrottleHelper.class, 'buildEndpoint')); 

from('direct:regular').to('hbase'); 

from('direct:throttle').to('hdfs'); 

내 ThrottleHelper 클래스의 buildEndpoint 방법은 다음과 같습니다

public static String buildEndpoint() { 
    synchronized(shouldThrottle) { 
     if(shouldThrottle) 
     return "direct:throttle"; 
     else 
     return "direct:regular" 
    } 
} 

을 현재 내가에서 checkStatus()라는 클래스의 방법이있다; shouldThrottle (정적 변수)을 설정합니다. checkStatus()는 매분마다 Camel 석영 타이머에서 실행됩니다.

나는 이상한 행동을 감지했으며, 나는이 패턴을 오용하고 있다고 생각합니다. Camel의 패턴 구현에 대한 추가 검색에서, 리턴 된 각 엔드 포인트가 메시지에 의해 통과 된 후에 buildEndpoint()가 호출되는 것처럼 보입니다. 사실입니까? 또는 "direct : throttle"또는 "direct : regular"로 이동 한 후에 경로가 종료 될 것으로 예상 할 수 있습니까?

내가 웹상에서 수집 한 것부터 내 방법이 실제로 이렇게 보이게해야합니까?

public static String buildEndpoint(Message message) { 
    if(message.getHeader('throttled') != null) 
     return null; 
    else 
     message.setHeader('throttled', true); 

    synchronized(shouldThrottle) { 
     if(shouldThrottle) 
     return "direct:throttle"; 
     else 
     return "direct:regular" 
    } 
} 

고마워요!

Answer 1

official documentation에서 두 번째 구문이 올바른 사용법에 더 가깝습니다. 기본적으로 동적 라우터는 즉시 종료되는 단일 끝점뿐만 아니라 여러 끝점을 통해 메시지를 라우팅하는 데 사용할 수 있습니다. 동적 라우터에게 메시지를 다른 엔드 포인트로 라우트하는 것을 중지 시키려면, 최종 메시지 스니 j에서 작성한대로이 메시지의 라우팅이 완료되었음을 나타 내기 위해 bean은 null을 리턴해야합니다.

Answer 2

프로그래머가 지적한 것처럼 동적 라우터는 여러 끝점을 통해 메시지를 라우팅하는 데 사용되므로 명시 적으로 null을 반환하여 라우팅의 끝을 나타낼 필요가 있습니다.

표현식 또는 bean 메소드를 사용하여 단일 끝점을 선택하기 만하면 동적 수신자 목록을 사용하는 것이 더 좋습니다 (cfr http://camel.apache.org/recipient-list.html). 경로 작성기에서 .dynamicRoute() 대신 .recipientList()을 사용하면 첫 번째 buildEndpoint 메소드 구현이 정상적으로 작동합니다.