[CAMEL-18013] camel-resume-api: pause API should allow finer control for pausable exceptions

• Type: Improvement
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Fix Version/s: Future
• Component/s: camel-resume-api
• Estimated Complexity: Unknown
• Assignee: Otavio Rodolfo Piske
• Reporter: Otavio Rodolfo Piske
• Created: 26/Apr/22 08:30
• Updated: 26/Apr/22 08:38

Description

I think we should be able to allow finer control of which exceptions can trigger a pause and which doesn't. For instance, we should be able to do something like:

 

 

onException(SomeException.class)
       .pausable(consumerListener, o -> canContinue());
from(from).routeId("pausable-it")
     .process(exchange -> LOG.info("Got record from Kafka: {}", exchange.getMessage().getBody()))
     .to(intermediate);

So that if AnotherException is thrown, the consumer does not pause.

Note: those using the circuit breaker can already filter unwanted exceptions via the event publisher - although, it is not very elegant.