amqp

    2熱度

    1回答

    我試圖連接我的RabbitMQ服務器,它被迫使用SSL,並且使用用戶和密碼進行保護。以前,我成功地從C#,PHP和Python應用程序連接到此服務器。 這是我的Node.js代碼: const amqp = require('amqplib'); const fs = require('fs'); const config = {...} const opts = { ca:

    0熱度

    1回答

    我嘗試使用在我的一個Android應用程序中使用AMQP消息隊列。我首先在java應用程序中測試了代碼,並且沒有任何問題,但是當我將相同的代碼放入Android應用程序時,沒有發生錯誤,但AMQP通道在收到第一條消息後意外關閉。我試圖添加一個關閉監聽器的通道,但它沒有返回任何東西。有人能幫我弄清楚爲什麼Rabbitmq頻道正在關閉? // -----------------------------

    0熱度

    1回答

    我試圖在我的項目中使用Server Side Events機制。 (這類似於類固醇上的長輪詢) 來自「Sending events from the server」字幕的例子效果非常好。幾秒鐘後,斷開連接,apache進程終止。此方法工作正常。 但是!如果我嘗試使用RabbitMQ,則在瀏覽器從服務器斷開連接後,Apache不會導致進程中斷(es.close())。並且進程保持原樣並在docker

    0熱度

    2回答

    我試圖發送使用AMQP QPID Java庫 我收到此錯誤信息服務總線的會話ID: "SessionId needs to be set for all brokered messages to a Partitioned Topic that supports Ordering" 我演講的題目有「強制消息排序」開啓(這是後我得到這個錯誤我猜) 在使用Azure的服務總線的Java庫(而不是AMQ

    0熱度

    2回答

    我有多個隊列,我們​​假設這些是Q1和Q2。 我也有一些任務,其中之一是T1。 如何配置芹菜,以便工人只需要T1從Q1,並從不接受Q2T1?

    0熱度

    1回答

    我想深入瞭解客戶端和RabbitMQ服務器之間的Push API通信是如何工作的。 據我所知 - 但糾正我的情況下 - 客戶端打開一個TCP連接到代理(RabbitMQ),並保持這個連接活着,直到客戶決定關閉它。但在此連接期間,客戶端可以立即獲取消息。 我的問題是,在這個連接期間,客戶端監視代理以詢問他的消息,或者當代理將消息轉發給隊列,客戶端訂閱時,只需要連接並將數據推送到客戶? 第一種情況:客

    0熱度

    1回答

    是否有可能讓RabbitMQ Consumer通過AMQP協議偵聽隊列中的消息。我知道nginx只支持HTTP/s協議。想知道這是否可以通過使用TCP模塊擴展來實現。 我正在使用nginx作爲API網關,並且希望執行從AMQP到HTTP的協議轉換,因爲所有後端服務都在HTTP上公開。

    -4熱度

    2回答

    我有一個場景,發佈者需要向已知交換機發送消息(他們不會直接知道下游隊列)。大部分消息應該傳遞給每個綁定隊列(如扇出),但有些消息只需要傳遞給特定的綁定隊列。我想避免多次交換以及多個隊列債券。 我當前的解決方案使用頭部路由,其中​​消息具有兩個頭中的一個,將其標識爲「全局」或「特定於某個特定子」,其中下游隊列綁定在匹配上 - 頭。我認爲這會起作用,但我覺得應該有一個更簡單的解決方案。 我試圖找到一個

    0熱度

    1回答

    我有許多可以執行某些操作的機器。要發起一個動作,我想發送一條消息到一個由機器ID命名的隊列,例如「12345」。 爲了避免其他人使用這些消息,我認爲隊列應該是排他性的。 但是從我的控制器來看,如果隊列在使用它的機器上聲明爲獨佔隊列,我就無法聲明這個隊列。但是,我可以通過指定其名稱來發送隊列,但沒有斷言,但我認爲這是不好的做法? 該機監聽命令是這樣的: ch.assertQueue(machineI

    0熱度

    1回答

    我試圖連接到使用,the example provided on microsoft website窗口服務總線,嘗試使用AMQP服務總線從Java private String SbConnStrACS = "amqps://" + SbUsername + ":" + encode(SbPassword) + "@" + SbDomain; private String SbQueueNam