2016-09-29 6 views
3

ActiveMQに問題があります。私はMaxReconnectAttempsを使用して接続しようとしていますが、そのプロパティを無視するようです。私は無効な宛先を入れているので、2回接続しようとしていますが、無期限に接続しようとしているようです。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); 
     } 
    } 

答えて

2

は、.NETクライアントを使用しているので、あなたはあなたがこのようなオプションを渡す必要がありmaxReconnectAttemptsを設定するには、フェールオーバーの輸送のためのURIオプションに接頭辞を使用する必要があります。

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

使用しているクライアントのドキュメントであるhereを確認することをお勧めします。

+0

ありがとうございました...うまくいきました...私はドキュメントを読むときにこのオプションを試したと思っていました... – pmeyer

関連する問題