在 RabbitMQ Autoconfig ConnectionFactory Bean 上设置检测信号属性



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

我可以在那里做,

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

由于我没有为 CachingconnectionFactory 创建 bean,所以我没有分配该属性的地方,这是我看到的唯一位置。

是否有其他方法可以在自动配置的设置中在连接工厂上分配此属性?谢谢

请参阅 Spring 引导属性文档。

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

最新更新