Administrator
6 days ago 77f0205db7a5b9f3d0da4c8e18b7a706d5cf37b7
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