1
예 경로 :Camel onException은 idempotentConsumer의 NoMessageIdException을 catch하지 않습니까?
onException(Exception.class)
.process(new Processor() {
@Override
public void process(Exchange exchange) throws Exception {
System.out.println("it works");
}
})
.handled(true);
from("jetty://http://0.0.0.0:8888/test")
.idempotentConsumer(header("myid"), MemoryIdempotentRepository.memoryIdempotentRepository(1000000))
.skipDuplicate(false)
.filter(property(Exchange.DUPLICATE_MESSAGE).isEqualTo(true))
.throwException(new DuplicateRequestException())
.end();
대한 myid 파라미터없이 수신기 URL에 요청을 전송은 org.apache.camel.processor.idempotent.NoMessageIdException 예외 : 메시지 헤더 (대한 myid) 없음 메시지 ID는 식을 사용하여 발견 할 수 없었다 교환 : 교환 [메시지 : [몸체는 org.apache.camel.StreamCache의 인스턴스입니다]]
onException을 통과하지 않고.
당신은이 "작동"인쇄되지 않는 건가요? –
예, 그렇지 않습니다. –