Публикация и получение подтверждений / подтверждений работает должным образом. Меня беспокоит то, что он не закрывает лишние каналы, которые не используются. С другой стороны, если для параметра Publisher Confirms установлено значение false, неиспользуемые каналы закрываются, как ожидалось.
Пример ConnectionFactory:
cachingConnectionFactory.setCacheMode(CachingConnectionFactory.CacheMode.CHANNEL);
cachingConnectionFactory.setChannelCacheSize(confirmChannelCacheSize);
cachingConnectionFactory.setPublisherConfirms(Boolean.TRUE);
cachingConnectionFactory.setPublisherReturns(Boolean.TRUE);
Образец RabbitTemplate:
template.setMandatory(true);
template.setConfirmCallback(deepConfirmCallback);
template.setReturnCallback(returnCallback);
Зависимость Spring AMQP:
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
<version>2.1.1.RELEASE</version>
</dependency>