Estoy usando Camel para mi aplicación de mensajería. En mi caso de uso tengo un productor (que es RabbitMQ aquí), y el consumidor es un bean.

from("rabbitmq://127.0.0.1:5672/exDemo?queue=testQueue&username=guest&password=guest&autoAck=false&durable=true&exchangeType=direct&autoDelete=false")
                .throttle(100).timePeriodMillis(10000)
                .process(new Processor() {                              
                        @Override
                        public void process(Exchange exchange) throws Exception {
                            MyCustomConsumer.consume(exchange.getIn().getBody())
                        }
                    });

Aparentemente, cuando autoAck es falso, se envía un reconocimiento cuando finaliza la ejecución del proceso () (corríjame si me equivoco aquí)

Ahora no quiero reconocer cuándo finaliza la ejecución del proceso (), quiero hacerlo en una etapa posterior. tengo unBlockingQueue en mi MyCustomConsumer donde consume () está poniendo mensajes, y MyCustomConsumer tiene un mecanismo diferente para procesarlos. Deseo reconocer el mensaje solo cuando MyCustomConsumer termine de procesar los mensajes deBlockingQueue. ¿Cómo puedo conseguir esto?