Подключение Spring boot 2 к rabbitmq через Apache Camel - PullRequest
Новая
       16

Подключение Spring boot 2 к rabbitmq через Apache Camel

0 голосов
/ 06 марта 2019

У меня проблема с подключением к rabbitmq через Apache Camel в Spring Boot 2.

Я сделал следующие шаги:

Мои зависимости: 

implementation "org.apache.camel:camel-spring-boot-starter:${camelVersion}"
implementation "org.apache.camel:camel-jackson-starter:${camelVersion}"
implementation "org.apache.camel:camel-core:${camelVersion}"
implementation "org.apache.camel:camel-rabbitmq-starter:${camelVersion}"
implementation "org.springframework.boot:spring-boot-starter-amqp"

Application.yaml 

spring:
      rabbitmq:
      dynamic: true
      host: 192.168.1.1
      port: 5672
      username: X
      password: Y

И у меня есть следующий маршрут: 

@Component
public class BasicRoute extends RouteBuilder {

@Override
public void configure() throws Exception {

    from("direct:loggerQueue")
            .id("loggerQueue")
            .to("rabbitmq://TEST-QUEUE.exchange?queue=TEST-QUEUE.queue&autoDelete=false&connectionFactory=#rabbitConnectionFactory")
            .end();
}

}

Finnaly У меня все еще есть следующая проблема:

2019-03-06 12: 46: 05.766 WARN 19464 --- [restartedMain] o.a.c.c.rabbitmq.RabbitMQProducer: не удалось создать соединение. Он попытается подключиться снова при публикации сообщения. java.net.ConnectException: в соединении отказано: соединение

Соединение кажется нормальным, я его проверил. Что-то плохое с rabbitConnectionFactory.

Я не знаю, что у меня плохого.

...