엔드 포인트가없는 프로세서 사용

Camel에 처음 생겼습니다. 처리 파이프 라인을 도청해야하며 내부에 흐르는 이벤트를 검사하고 statsd 메트릭을 전송하는 을 검사해야합니다. 코드 이 같은과 같습니다엔드 포인트가없는 프로세서 사용

Processor statsdProcessor = new StatsDProcessor(); 
... 
from("disruptor:wiretap").process(statsdProcessor);

disruptor:wiretap 이미 주요 파이프 라인에 연결되어 있습니다.

끝점없이 to() 끝점을 사용하지 않고 prossor를 사용한다는 의미가 궁금합니다. exchanges은 아니요, 시간 초과가 될 때까지 어디로 가야합니까? 아니면 버퍼가 가득 차서 덮어 쓰기 때문에 메모리에 저장됩니까?

출처

2014-09-22 dongshengcn

는 다음 아파치 낙타 내부의 모든 단지 processor, 예 to이있는 processor specialzed 등의 메시지가 낙타에 의해 라우팅 그래서

, 그 기본적으로 그냥

from X 
    process 
    process 
    process 
    ...

그래서이없는 카멜에서 경로를 정의 할 암시는 없습니다. 그것 모두가 -> 프로세스 -> 프로세스 등에서 온 것입니다.

출처

2014-09-22 16:53:54

"싱크"입니다. 입력과 출력이 없으며 적어도 파이프 라인으로 다시 출력되지 않습니다. 다른 예로는 파일 싱크 (파일에 데이터 쓰기), 데이터베이스 싱크 등이 있습니다.

반대쪽은 "소스"- from() 및 to() 만있는 "소스"입니다. 외부 신호 (즉, Camel 프레임 워크가 아닌)에 의해 트리거되며 파이프 라인으로 데이터를 펌핑합니다 (Camel이 대신 함). 일반적인 예는 cron 작업 (시간 기반 트리거), REST 서비스, ActiveMQ 또는 MQSeries과 같은 대기열 시스템에 연결된 서비스입니다. 가장 낮은 수준에서 솔직히

출처

2014-09-22 14:55:32

엔드 포인트가없는 프로세서 사용

답변

관련 문제