我在我的项目中使用solace作为JMS提供程序。我使用spring CachingConnectionFactory来检索连接。在这个连接上,我创建了一个新的会话。MessageConsumer messageConsumer = new session.createConsumer(destination); // This is passed to new thread
我正在做一些故障转移测试当我从网络连接上拔出服务器时,它失败了。当我再次连接</em
问题是我已经定义了一些可能处于非活动状态的代理uri。那么来自ActiveMQConnectionFactory的createConnection不会抛出任何异常。我需要处理这种情况,如果createConnection因为uri不可用而无法工作,那么我应该将我的服务标记为不健康。Connection conn = null; final ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory("failover:(tcp://localho