如何在 ActiveMQ 中使用 MaxReconnectAttemps

Question

我遇到了 ActiveMQ 问题，我正在尝试使用 MaxReconnectAttemps 进行连接，但它似乎忽略了该属性。我放置了一个无效的目的地，因此它尝试连接两次，但似乎无限期地尝试连接。

关于设置它的任何想法？

谢谢，

IConnectionFactory factory = new ConnectionFactory(("failover://(tcp://localhost:61616)?initialReconnectDelay=2000&maxReconnectAttempts=2"));
    using (Connection connection = factory.CreateConnection(username,password) as Connection)
    {
        connection.ClientId = "ClientId"; 
        using (ISession session = connection.CreateSession())
        {
            IQueue queue = session.GetQueue(queueName);
            var producer = session.CreateProducer(queue);
            producer.DeliveryMode = MsgDeliveryMode.Persistent;
            ITextMessage request = session.CreateTextMessage("Hello World!");
            producer.Send(request);
        }
    } 

Answer 1

由于您使用的是 .NET 客户端，因此您需要在 URI 选项上使用前缀来进行故障转移传输，因此要配置 maxReconnectAttempts，您需要像这样传递选项：

failover:(tcp://localhost:61616)?transport.maxReconnectAttempts=3

最好查看您正在使用的客户端的文档here。