在 rabbitmq autoconfig connectionfactory bean 上设置 heartbeat 属性

Question

我应该如何在 rabbitmq spring 中的 CachingConnectionFactory bean 上设置心跳属性？这是在云铸造环境中。因此，应用程序将通过清单文件使用服务绑定，而我没有代理主机名。在我的 SimpleMessageListenerContainer bean 中，我使用了 CachingConnectionFactory bean，我猜它是由 Spring.

自动装配的

我可以在那里做，

@Bean
SimpleMessageListenerContainer container(CachingConnectionFactory connectionFactory,
            MessageListenerAdapter listenerAdapter) {
    SimpleMessageListenerContainer container = new SimpleMessageListenerContainer();
    connectionFactory.setRequestedHeartbeat(60);
    container.setConnectionFactory(connectionFactory);
    ...
}

因为我没有为 CachingconnectionFactory 创建 bean，所以我没有分配它的地方属性，这是我看到的唯一地方。

是否有任何其他方法可以在自动配置设置中将此属性分配给 ConnectionFactory？谢谢

Answer 1

参见Spring Boot Properties Documentation。

spring.rabbitmq.requested-heartbeat= # Requested heartbeat timeout, in seconds; zero for none.

在 rabbitmq autoconfig connectionfactory bean 上设置 heartbeat 属性

set heartbeat property on rabbitmq autoconfig connectionfactory bean

spring

cloud-foundry

spring-rabbit