List<Message> messages = new ArrayList<>(); ... rabbitTemplate.convertAndSend(exchange, routingKey, messages); rabbitTemplate.setConfirmCallback((correlationData, ack, cause) -> { if (ack) { } else { } }); rabbitTemplate.setReturnsCallback(returned -> { }); SimpleMessageListenerContainer container = new SimpleMessageListenerContainer(); container.setConnectionFactory(connectionFactory); container.setQueueNames(queueName); container.setPrefetchCount(10); container.setConcurrency(5); @Transactional @RabbitListener(queues = "queueName") public void processMessage(Message message) { }