py-amqplib

    3熱度

    1回答

    如何使用py-amqplib等待多個隊列中的消息

    我使用py-amqplib來訪問Python中的RabbitMQ。應用程序會不時收到關於某些MQ主題的請求。 它接收到這樣的請求時，它創建一個AMQP連接和一個信道，並開始一個新的線程來監聽消息的第一次： connection = amqp.Connection(host = host, userid = "guest", password = "guest", virtual_host = "/
    python message-queue rabbitmq amqp py-amqplib 2009-11-27

    5熱度

    2回答

    如何從RabbitMQ中刪除隊列綁定？

    我正在使用RabbitMQ按主題將消息路由到感興趣的訂閱者。每個用戶都有一個隊列，我將隊列綁定到他們感興趣的主題。我想讓用戶從主題列表中刪除一個項目。 在我的設置中，這需要從該用戶的隊列中「綁定」綁定的主題。 我正在使用pyamqplib，而且我沒有看到通過通道對象執行此操作的方法。他們是一種從隊列中刪除先前綁定的路由密鑰的方法嗎？
    rabbitmq amqp py-amqplib 2010-11-23

    4熱度

    2回答

    連接到消息隊列的多個消費者和生產者，這在AMQP中可能嗎？

    我想創建一個能夠OCR文本的進程的場。 我想過使用由多個OCR進程讀取的消息的單個隊列。 我想確保： 在隊列中的每個消息最終處理 工作或多或少均勻分佈 的圖像將僅由一個OCR處理被解析 OCR進程不會一次獲得多個消息（這樣任何其他免費的OCR進程都可以處理該消息）。 使用AMQP可以嗎？ 我打算使用python和rabbitmq
    python message-queue rabbitmq amqp py-amqplib 2010-01-29

    6熱度

    5回答

    等待一個超時的單個RabbitMQ消息

    我想發送消息到RabbitMQ服務器，然後等待回覆消息（在「回覆」隊列中）。當然，我不想永遠等待處理這些消息的應用程序停機 - 這需要超時。這聽起來像是一項非常基本的任務，但我找不到辦法做到這一點。我現在遇到了這個問題py-amqplib和RabbitMQ .NET client。 到目前爲止，我已經得到了最好的解決方案是使用basic_get在兩者之間sleep輪詢，但是這是很醜陋： def _
    .net python rabbitmq amqp py-amqplib 2010-05-10

    0熱度

    1回答

    py-amqp/flopsy：在Python中等待一個AMQP消息

    我有一個和this one類似的問題：在py-amqp/flopsy中很容易說「我將永遠等待，並且我想要這個回調每當有消息進來時都會被調用「，但我找不到任何方式說」好吧，我收到了我想要的消息，現在停止等待。「 （也許GOTO？只是在開玩笑...）有沒有這樣做的優雅方式？
    python amqp py-amqplib flopsy 2010-06-28

    2熱度

    3回答

    如何在AMQP的python客戶端使用basic.return進行監聽

    我想確保我的消息被傳送到隊列中。 爲此，我將強制參數添加到basic_publish中。 如果我的郵件未成功發送，還應該怎麼做才能收到basic.return郵件？ 我不能使用channel.wait()來收聽basic.return，因爲當我的郵件成功發送時，wait()函數將永久掛起。 （沒有超時） 另一方面。當我不呼叫channel.wait()時，channel.returned_mess
    python rabbitmq amqp py-amqplib 2010-02-03

    0熱度

    1回答

    Node.js + node_amqp.js無法連接到ActiveMQ 61616或5672端口

    需要一些建議。 這就是例子，這是我開始的node.js： var amqp = require('amqplib'); amqp.connect('amqp://localhost:61616').then(function(conn) { conn.once('SIGINT', function() { conn.close(); }); return con
    javascript node.js activemq node-amqp py-amqplib 2013-08-19

    10熱度

    3回答

    獲取RabbitMQ隊列中的消息數

    我們使用amqplib來發布/使用消息。我希望能夠讀取隊列中的消息數量（最好是已確認和未確認）。這將允許我向管理員用戶顯示一個很好的狀態圖，並檢測某個組件是否跟不上負載。 我在amqplib文檔中找不到關於讀取隊列狀態的任何信息。 有人能指出我正確的方向嗎？
    python rabbitmq message-queue py-amqplib 2013-05-22

    2熱度

    1回答

    用海帶和RabbitMQ的

    AMQP交易我似乎無法找到使用AMQP transactions通過Kombu API的任何文件。 This page關於追加一條消息，事務狀態會談，但它似乎並不相關。 我知道鼠後端支持他們，我敢肯定的amqplib後端（其中進出口目前使用）不太多，但我不還怎麼看這是在海帶曝光。 編輯：澄清，進出口尋找channel.commit（），channel.select（）...類型的方法
    transactions rabbitmq amqp kombu py-amqplib 2011-06-29

    1熱度

    2回答

    如何檢測交換不存在與py-amqp

    我希望能夠檢測在向AMQP提交消息時交換是否不存在。 考慮下面的例子。 #!/usr/bin/python import amqp from time import sleep conn = amqp.Connection(host="localhost:5672", userid="guest", password="guest", virtual_host="/") outgoin
    python amqp py-amqplib 2013-02-19
最新問題