Administrator
5 days ago b83f56cbce86714acb66145d637c9d3f2beb94bf
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