我应该如何在rabbitmq spring中的CachingConnectionFactory bean上设置heartbeat属性?
这是在云铸造环境中。因此,应用程序将通过清单文件使用服务绑定,并且我没有代理主机名。
在我的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 上分配此属性?
谢谢
See the Spring Boot 属性文档 http://docs.spring.io/spring-boot/docs/1.5.1.RELEASE/reference/htmlsingle/#common-application-properties.
spring.rabbitmq.requested-heartbeat= # Requested heartbeat timeout, in seconds; zero for none.
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)