如何自動重新連接ActiveMQ中的StompJmsConnectionFactory工廠

Question

將訂戶寫入Listen AMQ隊列。它正在工作，但我想在AMQ重新啓動或關閉時自動重新連接。爲此添加下面的代碼： -

StompJmsConnectionFactory factory = new StompJmsConnectionFactory(); 

      factory.setBrokerURI("failover:tcp://" + host + ":" + port+"?retryInterval=2000&reconnectAttempts=1000"); 

      connection = factory.createConnection(user, password); 

但這些設置不按預期工作，要重現的場景，我停了下來，而用戶正在運行AMQ和我調試的程序，看到隧道後的上面的代碼行來捕獲塊（連接被拒絕）。

未發現任何重新連接嘗試。任何想法？我錯了。 T刪除了故障轉移也我試過但相同的結果

Answer 1

這看起來像你正在使用的StompJMS客戶端，據我所知不是維護在所有更多，所以我不知道這是開始一個開發的最佳選擇與...合作。

由於您使用的是Java，爲什麼不只是使用ActiveMQ的本機Java JMS客戶端，它使用OpenWire協議，並提供了比STOMP客戶端更廣泛的功能和更好的支持？