Connection отказался от чтения с RabbitMQ Queue на Cloud Foundry с использованием Spring

Question

Я пытаюсь использовать RabbitMQ для размещения сообщений из одного приложения и получения их в другом. Эти приложения размещаются в Cloud Foundry, и оба они привязаны к одному экземпляру RabbitMQ.

Я могу отправлять сообщения в очередь из первого приложения, но в моем втором приложении, которое использует @RabbitListener и @RabbitHandler для прослушивания этой очереди, я получаю сообщение об ошибке «Отказано в соединении». Однако он хорошо работает на моем локальном экземпляре RabbitMQ.

Consumer raised exception, processing can restart if the connection factory supports it. Exception summary: org.springframework.amqp.AmqpConnectException: java.net.ConnectException: errno: 111 (Connection refused), error: Connection refused (local port 45596 to address 127.0.0.1 (localhost), remote port 5672 to address 127.0.0.1 (localhost))

Это полный журнал.

Удаленный порт, я наблюдаю, остается неизменным на уровне 5672, но локальный порт продолжает меняться с журнала на журнал. Я не уверен, откуда берутся эти порты, так как я полагаю, что Spring должна справиться с этим для меня, а также потому, что у меня есть аналогичная настройка для моего первого приложения, которое, кажется, работает нормально.

Вот как мой конфиг looks-

@Bean 
     public MessageConverter jsonMessageConverter(){ 
      return new Jackson2JsonMessageConverter(); 
     } 

     @Bean 
     public AmqpAdmin amqpAdmin(ConnectionFactory connectionFactory) { 
      return new RabbitAdmin(connectionFactory); 
     } 

     @Bean 
     public RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory) { 
      RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory); 
      rabbitTemplate.setMessageConverter(jsonMessageConverter()); 
      return rabbitTemplate; 
     } 

     @Bean 
     public SimpleMessageListenerContainer messageListenerContainer(ConnectionFactory rabbitConnectionFactory) { 
      SimpleMessageListenerContainer container = new SimpleMessageListenerContainer(); 
      container.setConnectionFactory(rabbitConnectionFactory); 
      container.setQueueNames("queue2911"); 
      container.setAutoStartup(false); 
      //container.setMessageListener(exampleListener()); 
      return container; 
     } 

Любая помощь будет оценена.

Answer 1

Операционная система выбирает локальный порт.

Тот факт, что вы пытаетесь подключиться к localhost, подразумевает, что вы используете фабрику соединений с настройками по умолчанию (localhost: 5672) вместо загруженной конфигурации.

Включите ведение журнала DEBUG для обоих приложений и сравните отчеты о автоматической конфигурации.