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

由於您使用您需要使用前綴上的故障轉移運輸的URI選擇.NET客戶端，因此要配置你需要通過選擇這樣maxReconnectAttempts：

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

這是一個好主意，請查看您使用的客戶端的文檔是here。