Hi,
I am looking for a way to add an (ListenerInvocation)ErrorHandler
to an event processor with dead-letter enabled.
The documented way (Spring Boot) to add an error handler does not work:
@Bean
public ConfigurerModule errorHandlerConfigurer() {
return configurer ->
configurer
.eventProcessing()
.registerDefaultErrorHandler(
conf ->
(errorContext) -> {
log.atError()
.log("error handling message: {}", errorContext.error().getMessage());
})
For a normal event handler (without DLQ) this works just fine. Through debugging I found it does nothing when dlq.enabled: true
for this processing group (so a DeadLetteringEventHandlerInvoker
is instantiated with a propagating error handler, not the one configured above).
Question: Is this intended behavior?
If so, how can I add error handling behavior to a dead-letter event processor?