| src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java | ●●●●● patch | view | raw | blame | history |
src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java
@@ -30,15 +30,7 @@ @Bean @Scope(ConfigurableBeanFactory.SCOPE_PROTOTYPE) public RabbitTemplate rabbitTemplate() { RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory); // 设置消息确认机制 rabbitTemplate.setConfirmCallback((correlationData, ack, cause) -> { if (!ack) { log.error("消息发送失败: {}", cause); } }); return rabbitTemplate; return new RabbitTemplate(connectionFactory); } @Bean