当Spring应用程序从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:错误创建名为“amqpInbound”的类路径资源com/mitchell/csg/acsstatefarmedibundler/filesHandler/FileMonitorBeanRegistry.class: bean通过工厂方法实例化失败；嵌套异常是org.springframework.beans.BeanInstantiationException:未能实例化org.springframework.integration.dsl.IntegrationFlow:工厂方法'amqpInbound‘抛出的异常；嵌套异常是java.lang.NoSuchMethodError: org.springframework.integration.amqp.support.DefaultAmqpHeaderMapper:方法()V未找到

这是我的pom.xml。

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

我是不是错过了这里的遗属？

Answer 1

由于您正在提到Spring，因此没有必要覆盖依赖的版本。现在看来，Spring版本不是2.1，这使得所有依赖项都与前面提到的兼容。

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