Invoke RabbitListenerErrorHandler when the batch of the listener is enabled about spring-amqp HOT 2 CLOSED

The RabbitListenerErrorHandler contract does not match with the batch:

Object handleError(Message amqpMessage, @Nullable org.springframework.messaging.Message<?> message,
			ListenerExecutionFailedException exception) throws Exception; 

in comparison with:

void onMessageBatch(List<Message> messages, Channel channel);

Since we have no knowledge with exactly message has failed in the batch when we call:

invokeHandlerAndProcessResult(null, channel, converted);

(see how an AMQP Message is null)
We leave the error handling here up to a generic ErrorHandler on the listener container level.

WDYT?

from spring-amqp.

The RabbitListenerErrorHandler contract does not match with the batch:

Object handleError(Message amqpMessage, @Nullable org.springframework.messaging.Message<?> message,
			ListenerExecutionFailedException exception) throws Exception; 

in comparison with:

void onMessageBatch(List<Message> messages, Channel channel);

Since we have no knowledge with exactly message has failed in the batch when we call:

invokeHandlerAndProcessResult(null, channel, converted);

(see how an AMQP Message is null) We leave the error handling here up to a generic ErrorHandler on the listener container level.

WDYT?

I got it. Because we have no knowledge with exactly message has failed during porcessing, except in our custom listener code.
I think this is the reason. And thank u for explaning to me.

from spring-amqp.