activemq

1熱度

1回答

我是MQTT的新成員，希望使用node.js創建MQTT客戶端，該客戶端接受身份驗證頭以連接到MQTT。要連接的URL是tcp：// ip_address：61616並且需要用戶名和sessionId。 [服務器使用activeMQ]。請幫我這個。

0熱度

2回答

將mqtt協議添加到artemis Wildfly

我想使用mqtt和Artemis activemq。我嘗試添加一個模塊爲mqtt exactely在這篇文章here。我的問題是一樣的，我看不到添加協議支持：MQTT。有人可以幫助我嗎？

0熱度

2回答

我有兩個Message Listener正在偵聽相同的消息。如何確保一個偵聽器先於另一個偵聽器執行其代碼？

我有一個原消息 Item.proto： Message SetItemThing { required string id; } CreateTableListener： public void onMessage(SetItemThing msg) { // Creates a table to put items in } CreateItemInTa

1熱度

1回答

客戶端隊列持久性

Amqp代理具有允許保證傳遞的持久性設置 - 但只有在消息實際到達代理時纔有效。如果出現網絡故障並且隨後的客戶端崩潰/重新啓動消息可能丟失。在rabbitmq或activemq或其他客戶端（生產者）的消息框架中是否有某種方式將消息保存到磁盤，以便在客戶端崩潰或重新啓動時，任何未發送的消息都不會丟失？我已經看到人們在本地運行經紀人以解決此問題。這似乎是不必要的工作量，尤其是如果您對客戶端的部署沒有

0熱度

1回答

隊列消費者有待處理的消息，但他們沒有得到處理

我使用activemq，駱駝和春天的組合。對於隊列，我們有多個消費者;在某些隊列消費者中，我們看到有未決消息（達到100，與預取相同），並且根本沒有得到處理，除了其他使用者處於同一隊列之外，它仍然是一切照舊。我深入瞭解發生了什麼事情，發現spring cachingconnectionfactory可能導致此問題 - 我們懷疑此緩存連接工廠可能會將某些客戶端設置爲非活動狀態，並且留在預取緩衝

2熱度

3回答

用ActiveMQ創建持久的主題和用戶彈簧引導jms

我需要爲ActiveMQ創建一個主題和一個持久訂閱者，我的問題是我不知道在哪裏指定。我可以創建主題並使用消息，但是當我關閉訂閱者時，請繼續發送消息並再次打開訂閱者，它不會讀取它們。這是我到目前爲止有：發送消息： JmsTemplate jmsTemplate = context.getBean(JmsTemplate.class); jmsTemplate.setPubSubDoma

0熱度

3回答

如何在活動mq Web控制檯localhost：8161中發送消息的消息標題（屬性）？

我在網上搜索了很多，找不到任何答案。

0熱度

1回答

STOMP在幾分鐘不活動後停止接收消息

我在ActiveMQ和Stomp連接中遇到了一個非常不尋常的問題。我已將它集成到我的網站中，當網站或計算機上有任何活動時（即使網站打開的瀏覽器最小化），它也能正常工作。只要計算機進入空閒模式超過10分鐘，ActiveMQ與STOMP之間的連接就會關閉，然後即使用戶再次使瀏覽器達到最大化，也不會有任何通信和更新。版本我使用ActiveMQ的：5.9.0 STOM：1.0.9 我使用以下配置設置

0熱度

2回答

將JSON消息轉換爲ActiveMq中的javax.jms.ObjectMessage

我有一個ActimeMQ使用者，它需要javax.jms.ObjectMessage格式的消息。此消息pojo有5個字符串元素。現在我正在嘗試在NodeJs中爲此使用者編寫消息生產者。我使用stompit模塊我當前的代碼的NodeJS是 stompit.connect(connectOptions, function(error, client) { if (error) {

0熱度

1回答

沒有消息隊列的進程間（服務）通信

我們想開發一個基於微服務體系結構的應用程序。要異步地在各種服務之間進行通信，我們計劃使用消息隊列（如RabbitMQ，ActiveMQ，JMS等）。有消息隊列可用於實現進程間通信嗎？謝謝。