Administrator
6 days ago db4b84b5dbfe90ba062cd6f536241afe3f19e746
refactor(rabbitmq): 简化 RabbitTemplate 配置

- 移除手动设置的消息确认回调逻辑
- 直接返回新的 RabbitTemplate 实例
- 依赖默认配置而非自定义确认机制
1 files modified
10 ■■■■ changed files
src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java 10 ●●●● 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