Spring Boot 应用程序从 RabbitMQ 使用时出现异常

Question

我的 springboot 应用程序中有以下代码

@Bean
    public IntegrationFlow amqpInbound(ConnectionFactory connectionFactory) {
        return IntegrationFlows.from(Amqp.inboundAdapter(connectionFactory, "aName"))
                .handle(m -> System.out.println(m.getPayload()))
                .get();
    }

当我运行启动应用程序时，出现以下异常！

org.springframework.beans.factory.BeanCreationException：在类路径资源 [com/mitchell/csg/acsstatefarmedibundler/filesHandler/FileMonitorBeanRegistry.class] 中定义名称为“amqpInbound”的 bean 创建错误：通过工厂方法进行 Bean 实例化失败；嵌套异常是 org.springframework.beans.BeanInstantiationException：无法实例化 [org.springframework.integration.dsl.IntegrationFlow]：工厂方法“amqpInbound”抛出异常；嵌套异常是 java.lang.NoSuchMethodError: org.springframework.integration.amqp.support.DefaultAmqpHeaderMapper: method ()V not found

这是我的 pom.xml。

 <dependency>
          <groupId>org.springframework.integration</groupId>
          <artifactId>spring-integration-amqp</artifactId>
          <version>5.1.0.RELEASE</version>
      </dependency>

我在这里缺少任何其他依赖项吗？

Answer 1

由于您提到了 Spring Boot，因此覆盖依赖版本是没有意义的。现在看起来你的 Spring Boot 版本不是 2.1 这使得所有依赖项都与提到的 Spring Integration 版本兼容。

嗯，对您来说，简单的答案是从 spring-integration-amqp 依赖项中删除一个版本，并完全依赖 Spring Boot 管理。