.NET中的ActiveMQ连接启动超时

Question

我有ActiveMQ的.Net客户端。我正在使用Apache.NMS 1.5.1.2739和Apache.NMS.ActiveMQ 1.5.6.2746

我使用以下代码连接到代理：

var connectionFactory = new ConnectionFactory("failover:tcp://127.0.0.1:61616/?transport.timeout=5000");
IConnection connection = connectionFactory.CreateConnection();
connection.Start();

问题是当没有可用的ActiveMQ代理时，connection.Start（）将永远挂起。因此，transport.timeout在这里没有帮助。我想Start（）方法超时。因此，在这段时间之后，发生异常，执行可能会继续进行。如何避免这样的问题？

Answer 1

我找到了正确的uri参数。整个uri应该看起来像这样一个

故障转移：（tcp：//127.0.0.1：61616 /）？transport.startupMaxReconnectAttempts = 2

但是请注意，如果发生异常，则ActiveMQ客户端将不再尝试重新连接，您需要自己进行连接。