2016-09-29 5 views
3

У меня проблема с ActiveMQ, я пытаюсь подключиться с помощью MaxReconnectAttemps, но, похоже, он игнорирует свойство. Я помещаю недействительный пункт назначения, поэтому он пытается подключиться дважды, но, похоже, пытается подключиться бесконечно.Как использовать MaxReconnectAttemps в ActiveMQ

Любые идеи относительно его настройки?

Спасибо,

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); 
     } 
    } 

ответ

2

Поскольку вы используете клиент .NET вы должны использовать префикс на параметры URI для отказоустойчивого транспорта, поэтому для настройки maxReconnectAttempts нужно передать параметр, как это:

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

Рекомендуется ознакомиться с документацией для используемого вами клиента, которая является here.

+0

Спасибо, что сработало ... Я думал, что пробовал эту опцию при чтении документации ... – pmeyer

Смежные вопросы