amqp

1熱度

2回答

Spring jms ListenerContainer與使用Qpid客戶端的AMQP拋出異常連接到Azure服務總線分區時主題

我正在使用AMQP將Jasure服務總線與Java qpid客戶端一起連接到Spring JMS。我將服務總線擴展到高級層，因爲主題是默認分區的，無法從門戶或Azure服務總線管理庫修改我在SimpleMessageListenerContainer的開始處遇到以下問題。的javax.jms.JMSException：無法打開一個主題客戶端的實體類型用戶。 TrackingId：74bcb8d

1熱度

1回答

RabbitMQ到Azure物聯網集線器？

目前我們想使用RabbitMQ訪問我們的Azure IoT-Hub。我們知道還有其他的選擇，並且已經測試了一些，但是這個項目是測試它是否可行並且適合我們。 using RabbitMQ.Client; using RabbitMQ.Client.Events; using System; using System.Text; 我們的代碼看起來有點像這樣： var factory = ne

0熱度

1回答

Azure Servicebus AMQP URL未被接受/或如何將Liberty連接到Azure服務總線

將Azure ServiceBus通過AMQP通過QPID連接到IBM WAS LibertyProfile時遇到問題。我跟着教程在Microsoft Docs Service Bus Messaging但我得到了以下異常（網址進行模糊處理）： Caused by: Not an AMQP URL amqps://POLICY:[email protected] at org.apache.q

1熱度

1回答

單獨的Web和工作進程應該爲每個進程打開一個新連接嗎？

我目前正在嘗試構建一個具有Web和工作進程的NodeJS Web應用程序，並使用AMQP在它們之間進行通信。使用我當前的設置，啓動應用程序需要啓動Web進程的腳本（server.js）和工作進程的另一個腳本（worker.js）。它們中的每一個include第三個文件，amqp.js它使用啓動功能，涉及創建一個連接，然後創建一個通道，然後斷言隊列。但是，在試圖調試另一個問題時，我遇到了this

0熱度

1回答

我可以在瀏覽器中使用amqplib嗎？

我是AMQP/RabbitMQ新手，和相關的Node.js新手。我可以使用amqplib NPM庫客戶端嗎？我希望能夠從我的Angular應用程序直接將消息推送到RabbitMQ。我用Browserify模塊化了很多客戶端代碼。我現在開始嘗試使用RabbitMQ，並希望通過amqp協議將消息直接從瀏覽器推送到基於雲的隊列。我已經通過NPM安裝amqplib並寫入/粘貼以下模塊： var amq

3熱度

1回答

如何在.NET中創建核心使用AMQP.Net精簡版庫持久發佈/訂閱話題的clientId和用戶名和主題名稱

我是新來ActiveMQ，但我想和我能夠創建一個持久的出版商，但我無法設置客戶端ID，因爲我沒有找到客戶端ID的任何屬性，甚至無法在Google中找到。如果我能得到一些示例代碼，這將非常有幫助。注意：不符合NMS協議。我在.NET Core Web API中使用了ActiveMQ的AMQP.Net Lite，用於創建具有ClientId的持久發佈者/訂閱者。

2熱度

1回答

未綁定扇出交換丟失數據

當我向Fanout交換（它尚未綁定到任何隊列）傳遞一些消息並停止發佈者時，發送到交換器的消息將丟失。交換停止。未綁定的Exchange是否可以保存發佈的消息？

0熱度

1回答

amqp協議點對點

我試圖用amqpnetlite發送消息點對點。我使用這個代碼：amqpnetlite peer to peer。我的問題是：我應該使用amqp代理嗎？這裏的確切代碼： string address = "amqp://guest:[email protected]:5672"; Uri addressUri = new Uri(address); ContainerHost host = n

0熱度

2回答

Spring AMQP - 將ListenerContainer傳給bean

我目前正在嘗試將Spring AMQP Listener Container傳遞給一個bean，因爲我需要動態更改監聽器的最大數量（但是我有內存限制，所以我需要比聽衆容器爲我提供了開箱即用的功能）。我的想法是創建一個每秒鐘都會調用的bean manageListenerContainer，並相應地更改concurrentConsumers屬性。但我無法弄清楚如何將listenerContain

1熱度

1回答

如何在Spring AMQP框架下捕獲AmqpConnectException？

當我停止RabbitMQ的服務器，下方將引發異常： org.springframework.amqp.AmqpConnectException: java.net.ConnectException: Connection refused: connect at org.springframework.amqp.rabbit.support.RabbitExceptionTranslato