我无法在 RabbitListener 上覆盖 containerFactory答案

【问题标题】：I cannot override containerFactory on RabbitListener我无法在 RabbitListener 上覆盖 containerFactory
【发布时间】：2021-07-06 12:17:49
【问题描述】：

我面临一个被覆盖的问题，更准确地说是在我的 RabbitListener 之一的 containerFactory 中。

假设我有 projectA，它的一个依赖项（库 B）在运行时实例化以下配置。

@Configuration
public class AmqpConfiguration {
    @Bean
    public static BeanPostProcessor bpp() {
        return new BeanPostProcessor() {

            @Override
            public Object postProcessAfterInitialization(Object bean, String beanName) throws BeansException {
                if (bean instanceof RabbitTemplate) {
                    RabbitTemplate rabbitTemplate = (RabbitTemplate) bean;
                    rabbitTemplate.addBeforePublishPostProcessors(new LogRequestBeforePublishPostProcessor());
                } else if (bean instanceof AbstractRabbitListenerContainerFactory) {
                    AbstractRabbitListenerContainerFactory<?> rabbitContainerFactory = (AbstractRabbitListenerContainerFactory<?>)  bean;
                    rabbitContainerFactory.setAfterReceivePostProcessors(new LogRequestAfterReceivePostProcessor());
                }
             
                return bean;
            }

        };

    }
}

如你所见，上面的 bean 在 RabbitTamplate 和 AbstractRabbitListenerContainerFactory 实例中注入了 MessagePostProcessor 的自定义实现。

我的问题是我想扩展或覆盖已在下面的代码中设置的 AbstractRabbitListenerContainerFactory 的 MessagePostProcessor。

rabbitContainerFactory.setAfterReceivePostProcessors(new LogRequestAfterReceivePostProcessor());

为了克服这种情况，我尝试创建一个 SimpleRabbitListenerContainerFactory 的新实例并将其传递给 projectA 中的 RabbitListener，但不幸的是我没有让它工作。使用调试模式我看到调用了 libraryB 的 MessagePostProcessor。

在下面查看我的测试代码。

@Configuration
public class LoggingContainerConfiguration {

  @Bean(name = "rabbitListenerContainerFactoryNew")
  public SimpleRabbitListenerContainerFactory simpleRabbitListenerContainerFactory(SimpleRabbitListenerContainerFactoryConfigurer configurer,
      ConnectionFactory connectionFactory, MessageConverter objJsonMessageConverter, ObjectMapper objectMapper) {

    SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
    configurer.configure(factory, connectionFactory);

    factory.setMessageConverter(objJsonMessageConverter);
    factory.setAfterReceivePostProcessors(new LogPaymentEventDTOAfterReceivePostProcessor(objectMapper));
    return factory;
  }
}

@RabbitListener(containerFactory = "rabbitListenerContainerFactoryNew",
                queues = {"test1", "test2"})
public void listener(Pojo pojo) {
   ...
}

您对如何在我的 RabbitListener 中覆盖 connectionFactory 的 MessagePostProcessor 有什么建议吗？

提前谢谢你。

【问题讨论】：

标签： spring-boot rabbitmq spring-amqp spring-rabbit

【解决方案1】：

项目 B 的 BPP 修改所有实例；不是按 bean 名称。

要么将其更改为仅修改其自己的 bean，要么您可以添加 SmartInitializingSingleton 以在 BPP 运行后重新修改您的 bean。

【讨论】：