Apache Kamel Idempotent Verbraucher Schlüssel Entfernung

Question

Ich habe eine Einstellung wie folgt.

Das Problem, das ich habe, ist, dass der Schlüssel aus dem Idempotent Repository nicht entfernt wird, wenn eine Ausnahme ausgelöst wird (in der Zeile unten angegeben) bei Verwendung seda Komponente innerhalb OnException. Wenn ich direct in OnException benutze, wird der Schlüssel aus dem Cache entfernt. Bei beiden Versuchen wird die E-Mail korrekt gesendet.

Meine Abfragen sind:

1. warum wird der Schlüssel aus dem Repository-Cache nicht, wenn innerhalb der OnException mit seda entfernt werden?
2. gibt es ein Problem mit der Verwendung von seda innerhalb der OnException? Hier

ist die Routen:

MyRouteClass1

onException(Exception.class) 
    .setHeader("subjectText", simple("failure email!")) 
    .to("seda:notifySupportOnFailure") 
    .end(); 

from("direct:findWorkItems") 
    .bean(someService, "findWorkItems") 
    .split(body()) 
     .throttle(1).timePeriodMillis(5000L) 
     .to("direct:handleWorkItem") 
     .choice().when(header("resultId").isGreaterThan(0)) 
     .bean(someService, "updateWorkItemToHandled") 
     .end(); 

from("direct:handleWorkItem") 
    .idempotentConsumer(simple("${body.workItemId}"), duplicatesRepo) 
    .bean(someService, "handleWorkItem") // e.g. exception would be thrown within here 
    .setHeader("resultId", body()) 
    .end(); 

MyRouteClass2

from("seda:notifySupportOnFailure") 
    .setHeader("from", simple("sender@mail.com")) 
    .setHeader("to", simple("recipient@mail.com")) 
    .setBody(simple("Failure:\n ${exception.message} \n\ndetail: \n${body}")) 
    .to("smtp://localhost") 
    .log("Failure email now sent.") 
    .end(); 

Ich habe auch eine andere Abhilfe versucht. Ich habe die onException Klausel wie unten geändert. Dies ermöglicht es, den Schlüssel aus dem Repository zu entfernen, wenn die Ausnahme ausgelöst wird. Ich frage mich, ob das ein richtiger Ansatz ist?

onException(Exception.class) 
    .setHeader("subjectText", simple("failure email!")) 
    .multicast().to("seda:notifySupportOnFailure").end() 
    .end(); 

Answer 1

Eine Arbeit um würde die idempotentConsumer Anruf in Ihrer Eltern-Route findWorkItems 'zu setzen und die completionEager Flagge auf sie auf true setzen.

onException(Exception.class) 
    .setHeader("subjectText", simple("failure email!")) 
    .to("seda:notifySupportOnFailure") 
    .end(); 

from("direct:findWorkItems") 
    .idempotentConsumer(simple("${body.workItemId}"), duplicatesRepo).completionEager(true) 
    .bean(someService, "findWorkItems") 
    .split(body()) 
     .throttle(1).timePeriodMillis(5000L) 
     .to("direct:handleWorkItem") 
     .choice().when(header("resultId").isGreaterThan(0)) 
     .bean(someService, "updateWorkItemToHandled") 
     .end(); 

from("direct:handleWorkItem") 
    .bean(someService, "handleWorkItem") // e.g. exception would be thrown within here 
    .setHeader("resultId", body()) 
    .end();