messagebroker

1熱度

1回答

MessageQueue的契約：MessageQueues情況下的樣本提供程序測試

我已經通過參考pact repo中給出的示例示例編寫了MessageProvider的樣本Pact測試。以下是正在生成用於提供者期望的消息的PACT json文件的消費者測試。在API的情況下，爲了驗證PACT，我可以使用「pact-jvm-provider-maven」插件來完成此操作。在這種情況下，PACT將根據提供商的實際託管API服務進行驗證。我的問題是，如何在MessageQueue

0熱度

1回答

訂閱一羣使用RabbitMQ的消費者？

我不能完全肯定這是提出正確的地方，但我對的RabbitMQ的運作問題，實現發佈/訂閱消息系統。我調查的RabbitMQ，看它是否適合我工作的公司的需要，我找不到任何回答這些問題無論是在官方文檔或在互聯網上：是否有可能爲一消費者訂閱一組發佈者？我想這是可能的，如果我們想要訂閱的所有發佈者都將他們的消息發送給交換機，然後將它們轉發給訂閱者。執行此操作最適合的呼氣類型是什麼？是否可以訂閱一組主題？例

0熱度

2回答

IBM Integration Bus和xsd：anyType

我正在使用IIB v9 mxsd消息定義。我想將其中一個XML元素定義爲xsd：anyType類型。然而，在我可以選擇的類型列表中，只有anySimpleType和anyUri是可能的（除了字符串，整數等所有其他類型）。我該如何解決這個限制？

0熱度

1回答

ActiveMQ將現有的隊列轉換爲CompositeQueue

我會盡我所能解釋這一點。正如我存儲我的數據，我從我的ActiveMQ的隊列接收在若干不同的位置，我已決定建立一個複合隊列，所以我可以分別處理每個位置的數據。我遇到的問題是，我目前擁有的隊列在生產環境中。看起來，將名爲A的隊列更改爲也稱爲A的組合隊列A具有名爲B和C的虛擬目標，這會導致我失去現有隊列中的所有數據。它不會啓動前面的消息。目前，我正在創建一個名稱不同的新CompositeQueue，

0熱度

1回答

MQTT，是否有可能爲本地主機以外的所有人阻止出版物，並將訂閱向所有人開放？

我想要做的只是從本地主機發布數據。但我需要允許Web上的任何用戶訂閱該主題，是否可以使用MQTT？怎麼樣？如果不是，我是否有其他的選擇來滿足這些細節。其他信息：使用MQTT協議張貼。使用Websockets進行訂閱。使用Mosquitto作爲經紀人。

1熱度

1回答

如何在Masstransit/RabbitMQ中組織隊列？

我想知道消費消息的最佳實踐。我已經閱讀了MassTransit文檔，並且正在尋找這方面的內容，但是我沒有得出任何結論。我有一個api（託管公交車實例），正在發佈消息。這些消息是多種多樣的，因爲這個API不是微服務（購買，銷售等的消息）。如何組織我的消費者/隊列？一個隊列類型的過程？例如，一個用於購買，另一個用於銷售，這個解決方案可能涉及許多流程，我不確定它是否是一個好的解決方案。如果我想購買

0熱度

1回答

對於節點應用程序只需要一個RbbitMQ連接，而不是每個發佈調用

每當我發佈新消息時，它都會創建一個新連接。我想只有一個連接和一個通道用於所有公共電話。從rabbitmq網站閱讀：某些應用程序需要多個連接到AMQP代理。但是，不希望同時打開許多TCP連接，因爲這樣做會佔用系統資源並使配置防火牆變得更加困難。 AMQP 0-9-1連接與可被認爲是「共享單個TCP連接的輕量級連接」的通道複用。但是如何？這裏是我的代碼： Channel.js var amqp

0熱度

1回答

嵌入式中間件ActiveMQ的配置

這是我的配置，用於將消息發送給嵌入式中間件。另外，第一個bean方法用於創建和啓動代理。它不返回任何實例。此代碼是否啓動代理？我已經使用JMS模板的發送方法將消息發送到下面提到的主題。我已經爲經紀人創建和運行寫了createbrokerervice。 @Configuration @EnableJms public class JMSConfig { public static

0熱度

1回答

什麼是消息代理重試intval和如何配置

我已經使用WSO2 Message Broker MB300服務器來通信每個微服務。這是使用主題連接。在儀表板「耐用主題訂閱」部分和「消息傳遞掛起數量」列消息中顯示爲掛起。這個數字正在增加。消息傳遞延遲或重試間隔的任何配置？

0熱度

1回答

MQTT代理是否支持持久訂閱？

我工作在我的第一個IOT POC上，設備通常會每小時/天產生一次傳感器數據。我打算有架構這樣的： - 1傳感器數據輸入（設備到後端方向）共享主題 - 每個設備將首先訂閱其自己的特定主題又名/設備/ {ID} /通知現在，在傳感器數據提交給共享主題後，我打算讓設備進入深度睡眠狀態（設備只能通過wifi數據包或定時器喚醒），在此狀態下，與代理的TCP連接丟失。問題：設備重新啓動並重新建立到MQT