如何在 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.