问题标签 [rabbitmq-exchange]

我正在尝试通过 puppet 安装 rabbitmq。我正在使用puppetlabs-rabbitmq模块。它还有配置队列和交换的部分，它们是Native Types. 我不知道如何使用这些本机类型。

我的rabbitmq安装代码：

我收到以下错误：

注意：当我省略这些原生类型时，rabbit 安装效果很好。

如何使用来Native Types配置rabbitmq_queue和？rabbitmq_exchangerabbitmq_binding

我正在尝试使用 Powershell 初始化 Exchange。我需要定义一个 DLQ，所以我正在尝试以下语法：

我收到此错误：

我在这个链接上看到可能并不那么容易：

参数字段在任何地方都被忽略。您不能使用参数创建队列、交换或绑定。带有参数的队列、交换或绑定不会显示这些参数

我想定义一个队列，以便将所有进入它的消息路由到不同的工作人员，同时与其中一名工作人员共享我想一张图可以更好地解释

W(i) - 接收不同消息的 Worker

W(sp) - 是接收所有消息的特殊工作者

Q - 队列

'----------------------------------------Q---------- ----------------

|--------------------------- |---------- -------- |
|--------------------------- |---------- -------- |
W1,W(sp)----------W2,W(sp)-----------W3,W(sp)

如您所见，W1、W2、W3、W4 都是不同的工作人员，每个工作人员都像普通工作人员一样接收不同的消息。每个人都会从队列中收到一份工作

然而，每个消息都应该像交换 W(sp) 一样共享。我怎样才能实现它。是否有一些我可以设置的参数，以便 W(sp) 始终可以接收队列中的所有事件

如果你能帮忙就太好了

编辑 1

我发现理解这个问题有点棘手，这是另一个版本

我想以循环方式共享队列中的作业，以便一个作业只给一个消费者一次，因为我想对作业进行并行处理，同时我想要一个特殊的消费者，它也将从队列中获取所有作业.

例如：

消费者 - C1,C2,C3,C4

特殊消费者 - Csp

队列-Q

Q 中的每个作业都应广播到 C1,C2,C3,C4 之一并与 Csp 共享。因此，来自 Q 的作业在 Csp 和 C(i) 之一之间共享。有了这个，我将能够并行处理 C1、C2、C3、C4 等中的作业，同时使用我的消费者 Csp 验证 Q 中的每个作业

我有以下配置

我在annoter-queue和consumer.queue上设置了 DLX，因此他们的消息在 1 秒后移动到consumer.exchange-dl 。

对于绑定到另一个交换（直接）的另一个队列，一切正常；发送到consumer.exchange (topic) 的消息不会移动到 DLX。我尝试使用 DLX 的路由键绑定，但没有任何效果。在 DLX 上进行主题交流有什么陷阱吗？

谢谢

我有 3 家福特、本田、日产汽车的不同经销商。他们都向我发送有关汽车及其规格的信息。

您会创建三个问题 ABCCarCompany.E.Direct.Honda ABCCarCompany.E.Direct.Nissan ABCCarCompany.E.Direct.Ford 还是只创建一个 ABCCarCompany.E.Direct.Cars 并让他们将汽车制造商作为参数发送......创建 3 个问题与 1 个 ..

我在尝试了解类型标头交换的工作原理时遇到了一些问题。

只有一个交易所，myExchange

三个队列：

1. 我的队列1
2. 我的队列2
3. 我的队列3

绑定：

1. myExchange => myQueue1 (x-match: any, myHeader: [test1])
2. myExchange => myQueue2 (x-match: any, myHeader: [test2])
3. myExchange => myQueue3 (x-match: any, myHeader: [test1, test2, test3])

我希望消息的标题有多个值；test1、test2、test3的任意组合 （例如：单独的 test1 、test1和test2 、 test3和test2等...）

myQueue3仅接收具有 myHeaders:[ test1, test2, test3 ] 的消息。我希望myQueue3也能获得例如test1和test2的消息。

myQueue1仅接收具有 myHeaders:[ test1 ] 的消息。我希望myQueue1也能获得例如test1和 [ test1 , test2 ] 的消息。

有没有办法实现这种行为？谢谢

我按照以下链接到消费者连接 http://pika.readthedocs.org/en/latest/examples/asynchronous_consumer_example.html

我观察到一种特殊的行为，每当我关闭工人并再次重新启动它时，它就会充斥着事件。不知道为什么。这些事件基本上是之前传递给它的事件。

我的理解是，这些事件仍保留在交换中，当我启动我的工作人员时，它会连接到交换并再次获取所有事件。顺便说一句，我正在使用扇出交换类型

我似乎在文档中找不到任何信息，所以我想知道是否有可能使用 java RabbitMQ API 获取与交换相关的所有绑定。

在查询 /api/bindings 时，我正在寻找类似 http api 结果的东西。

我在 Map 中有消息 - 作为队列名称的键和作为消息列表的值。每当我将多条消息发布到队列服务器时，都会引发异常，因为用户已达到允许的最大登录次数。

同时将消息发布到 1 个队列。下面是执行的代码：

}

如何将调试器附加到正在运行的 erlang 进程（rabbitmq）？我有正在运行的同一个兔子版本的源代码。我想在源代码行设置断点，并将调试器附加到正在运行的兔子实例。我不确定erlang是否需要调试符号async_dirty。

在一个完美的世界里，我希望能够在本地和远程做到这一点。