PROSAGA码农传奇-rabbitmq-Spring AMQP Stale消费者在PCF上使用RabbitMQ

Spring AMQP Stale消费者在PCF上使用RabbitMQ

作者: 时间
发布时间: 2024-07-17 04:16:22 (1月前)
转自：

<div class =“post-text”itemprop =“text”>
  <BLOCKQUOTE>
    <P>
      我们使用的是Spring Boot 1.5.9，Framework 4.3.6，AMQP 1.7.4，RabbitMQ AMQP Client 4.0.3
    </p>
  </BLOCKQUOTE>
  <P>
    从2.0版开始，Spring AMQP禁用了
     <code>
      automaticRecoveryEnabled
    </code>
     在目标RabbitMQ上
     <code>
      ConnectionFactory
    </code>
    ：
    <a href="https://docs.spring.io/spring-amqp/docs/2.1.4.RELEASE/reference/#auto-recovery" rel="nofollow noreferrer">
      https://docs.spring.io/spring-amqp/docs/2.1.4.RELEASE/reference/#auto-recovery
    </A>
  </p>
  <P>
    由于您使用的版本基于RabbitMQ
     <code>
      ConnectionFactory
    </code>
     由Cloud Connectors提供，您需要显式禁用它：
  </p>
   <pre>
    <code>
      @Bean
@Primary
public ConnectionFactory connectionFactory(){
    ConnectionFactory connectionFactory = cloud().getSingletonServiceConnector(ConnectionFactory.class, null);
    ((CachingConnectionFactory) connectionFactory).getRabbitConnectionFactory().setAutomaticRecoveryEnabled(false);
    return connectionFactory;
}

</code>
  </pre>
  <P>
    您的解决方案将基于Spring AMQP提供的恢复机制。
  </p>
</DIV>