В моем приложении 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: Ошибка при создании bean-компонента с именем «amqpInbound», определенного в ресурсе пути к классу [com / mitchell / csg / acsstatefarmedibundler / filesHandler / FileMonitorBeanRegistry.class]: сбой создания экземпляра компонента с помощью метода фабрики;вложенным исключением является org.springframework.beans.BeanInstantiationException: не удалось создать экземпляр [org.springframework.integration.dsl.IntegrationFlow]: фабричный метод 'amqpInbound' вызвал исключение;Вложенное исключение - java.lang.NoSuchMethodError: org.springframework.integration.amqp.support.DefaultAmqpHeaderMapper: method () V не найдено
Вот мой pom.xml.
<dependency>
<groupId>org.springframework.integration</groupId>
<artifactId>spring-integration-amqp</artifactId>
<version>5.1.0.RELEASE</version>
</dependency>
Я скучаю по какой-либо другой зависимости здесь?