messagebroker

0熱度

1回答

在下面的代碼中，我試圖爲持久數據創建一個文件夾。如您所見，我創建了private final String folder = "//temp";和對象persistence。但問題是當我運行應用程序，我說Connection Failed，這條消息從client connection synchronous listener出來，當我連接沒有對象persistence，每件事情都很好。我錯誤地初

0熱度

1回答

服務器DISCONNECT和我收到LWT消息？

如果服務器在(1.5) * KeepAlivetime內沒有收到來自客戶端的任何消息，並且客戶端沒有在上述期限內發送任何PINGREQ，則服務器應該是DISCONNECT？如果是，爲什麼我收到的LWT消息不應該被接收爲DISCONNECT發生？

1熱度

2回答

如何停止接收LWT保留的消息？

爲了測試，我創建了一個clean sessin = false和setWill(WILL_TOPIC, WILL_MSG.getBytes(), 1, true);的客戶端，並運行該應用程序。後來，當我運行應用程序時，我設置了setWill(WILL_TOPIC, WILL_MSG.getBytes(), 1, false);，我收到了以前重新登錄的LWT消息。如何停止接收它們？

4熱度

1回答

在特定MQ羣集上放置

我正在使用WebSphere MQ。我有3個QM：QM1，QM2和QM3。 QM1和QM2一起構成名爲CLS12的MQ集羣，而QM2和QM3構成CLS23。換句話說，QM2有兩個集羣。我想在QM2上放置一條消息（實際上是IIB來放置消息），但目標隊列實際上在QM1和QM3上是本地的，但是在羣集中共享。但是，我希望能夠選擇哪個羣集（而不是QM）消息應該被放置。這可能嗎？

0熱度

1回答

關於MQTT PubAck與QoS等級一個

在this tutorial在message options 默認情況下，部分中，一個新的消息實例被設置爲「至少一次」，服務質量的1質量（QoS），其指發送方將至少一次傳遞消息，如果沒有它的確認，它會保持與重複標誌設置發送它，直到確認輪番上漲，這是否意味着在setCallback listener-> onMessageArrived()我有要檢查是否有消息到達，我必須再次用重複標誌重新發送消息

0熱度

2回答

泛美衛生組織JS無法連接到服務器Mosquitto

當我試圖通過這個JS連接到服務器Mosquitto，我收到此錯誤： WebSocket connection to 'ws://xx.xxx.xxx.xxx:1883/mqtt' failed: Error during WebSocket handshake: net::ERR_CONNECTION_RESET 我從控制檯嘗試和它工作正常。我試圖用Java客戶端作爲提供者和消費者，它工作正

1熱度

1回答

使用ESQL檢查數據庫中的更新無循環

我無法解決一個問題。我正在與IBM WebSphere合作，我的任務如下：我在數據庫（SQL Server 2008）中只有一個記錄 - ID和名字。我輸入節點 - >計算節點 - >計算節點2 - >輸出節點在我需要檢查，如果在數據庫表中，第一個名字是約翰第一個計算節點（例如）。如果是約翰，那麼當數據庫中的姓名與約翰不同時，我需要在那裏停止消息。但不是循環，我需要解決沒有循環，因爲如果我在

0熱度

1回答

如何使用Java啓動/停止Websphere Message Broker？

我希望我的J2EE應用程序能夠以編程方式啓動/停止Websphere Message Broker 7.0.1或Integration Bus 9. MQ Explorer已具備此功能，因此我知道可以使用java編寫此代碼。我應該使用什麼工具來實現此功能？我已經嘗試了MQ Java API，PCF和CMP API，但沒有找到任何特定的命令。

0熱度

1回答

與oracle express的消息代理數據連接11g

如何從web-sphere消息代理8創建「oracle 11g express」連接？它給出了一個錯誤「無效的驅動程序定義，jar找不到」。

0熱度

1回答

XMLNSC屬性

我從應用 field:CHARACTER:abcd mv:CHARACTER:1 name:CHARACTER:NAME sv:CHARACTER:1 field:CHARACTER:aaaaa mv:CHARACTER:1 name:CHARACTER:Address sv:CHARAC