rabbitmq-exchange

    0熱度

    1回答

    我有一個隊列,其中多個消費者以循環方式工作。 Delivery_tag用於消費者完成其處理後的確認消息。但多個消費者設置相同delivery_tag,雖然他們正在工作的消息是不同的。 由於這樣做,當完成了,我得到precondition failed。 任何人都可以建議我做錯了什麼? 這是消費者code.I得到它從這個鏈接: http://blogs.digitar.com/jjww/2009/0

    0熱度

    1回答

    我有一個連接到RabbitMQ的(3.2.4)不可刪除的扇出交換稱爲「my_exhange_foo」一個Java應用程序的消費者交換的: Connection connection = connectionFactory.newConnection(consumerPool); Channel channel = connection.createChannel(); channel.exch

    0熱度

    1回答

    請先查看我的代碼。 這是我的測試類這是創建2000線程和那些線程正在發送消息。 public class MessageSenderMultipleThreadMock { @Autowired MessageList message; @Autowired MessageSender sender; public boolean process

    0熱度

    1回答

    是否可以使用RabbitMQ話題交換實現以下場景。 可以說我有兩個隊列: 隊列1:路由關鍵MainRoute.Route1 隊列2:路由關鍵MainRoute.Route2 當我發表我的路由關鍵信息: MainRoute.Route1 - >隊列1 MainRoute.Route2 - >隊列2 MainRoute - >隊列1和隊列2 是否有可能實現這一點而不實現一些特殊的過濾,路由過程? 如果

    2熱度

    2回答

    如何將調試器附加到正在運行的erlang進程(rabbitmq)?我有運行相同的兔子版本的源代碼。我想在源代碼行上設置斷點,並將調試器附加到正在運行的兔子實例。我不確定erlang是否需要調試符號async_dirty。 在一個完美的世界中,我希望能夠做到這一點,無論是本地和遠程。 我是這樣一個erlang初學者,我甚至不會說我是erlang的新手。我只是想在我調試一些rabbitmq插件時學習它

    0熱度

    2回答

    在我在網上找到的所有示例中,我看到交換和隊列在消息消耗之前被聲明。 宣佈交換似乎很奇怪,因爲,爲什麼我會這樣做?我正在使用一個隊列,它可能會綁定到多個交換器(或者沒有,也可能只是有舊的消息在等待)。 另外,我想不出爲什麼我會聲明一個隊列。這將要求我知道關於隊列的信息,我不需要知道它們的使用情況(如auto_delete和durability)。 當我在本地測試它時,我可以在不聲明任何內容的情況下使

    0熱度

    1回答

    在Rabbit MQ中使用集羣時,我打算使用Competing Subscriber模式。 Producer : 1 Exchange : 1 direct Queue : 1 Consumers : n (multiple) listening to the same queue. 現在,如果我有一個包含3個節點的羣集中,會有但是從其中消費者獲取消息(無論在集羣節點的數目的)一個隊列。

    1熱度

    2回答

    我無法弄清楚使用RabbitMQ中提供的不同交換類型的實際情況。

    0熱度

    1回答

    一旦我在Visual Studio中啓動應用程序,就會收到SharedQueue關閉錯誤。現在錯誤非常頻繁。據我所知,我們還沒有對代碼&做出任何更改,此代碼在早期工作良好。 我看到很多類似的錯誤發佈在網上,所以我沒有找到任何有用的帖子。當異常發生時,它不會指向任何代碼。請參閱下面的錯誤的詳細信息: 以下是錯誤堆棧跟蹤: at RabbitMQ.Util.SharedQueue.EnsureIsOp

    0熱度

    1回答

    我有一些問題,試圖瞭解如何交換標題工程。 只有一個交換,myExchange 三個隊列: myQueue1 myQueue2 myQueue3 綁定: myExchange => myQueue1(X-匹配:任何,myHeader:[TEST1]) myExchange => myQueue2(X-匹配:任何,myHeader:[TEST2]) myExchange => myQueue3(X-匹