问即使保存失败，也会确认WebFlux/Reactive Spring RabbitmMq消息

EN

@RabbitListener(queues = Constants.SOME_QUEUE, returnExceptions = "true")
public void receiveMessage(final List<ItemList> itemList) {
    log.info("Received message from queue: {}", Constants.SOME_QUEUE);
    itemService.saveAll(itemList)
            .subscribe(
                    item-> log.info("Saving item with {}", item.getId()),
                    error -> {
                        log.error("Error during saving item", error);
                        throw new AmqpRejectAndDontRequeueException(error.getMessage());
                    },
                    () -> log.info(Constants.SOME_QUEUE+
                            " queue - {} items saved", itemList.size())
            );
}