2014-10-19 1 views
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을 통과하지 않고.

+0

당신은이 "작동"인쇄되지 않는 건가요? –

+0

예, 그렇지 않습니다. –

답변

관련 문제