问题标签 [rabbitmq-shovel]

使用spring XML，就像我们创建队列，绑定等如下

我们也可以制造铲子吗？

请告诉我。我想自动创建动态铲子。不是手动通过管理插件。

我使用rabbitmqctl set_parameter shovel“MyShovel”创建了铲子......

现在我想删除它，你能告诉我如何使用命令行来实现它。

是否可以配置 2 个 Rmq 服务器以便在它们之间使用直接回复？

例如

RpcClient 连接服务器 1 并调用连接到服务器 2 的 RpcServer。

是否可以铲/联合伪队列amq.rabbitmq.reply-to

提前致谢！

我已经为单个消费者发布了一些优先级设置的消息（即可以根据消息优先级接收消息的单个消费者）。我想要的是获取这些消息并根据消费者端的消息优先级打印它们。嘿伙计们帮我解决这个问题！

在上面的代码中，我使用线程来传递优先级和消息值，并同时启动两个线程来发布具有不同优先级的消息。我已经在 AMQ Builder 中设置了优先级值。

编辑：在系统环境变量中设置 rabbitmq 变量并尝试另一个卸载/重新安装后，问题得到解决。

以下插件已启用：rabbitmq_shovel

将插件配置应用于 rabbit@MSGTEST01... 启动了 1 个插件。

结束编辑

c:\RabbitMQ\rabbitmq_server-3.6.12\sbin>rabbitmq-plugins enable rabbitmq_shovel rabbitmq_shovel_management 插件配置不变。

将插件配置应用于 rabbit@M... 失败。错误：{enabled_plugins_mismatch,"c:\Users\\AppData\Roaming\RabbitMQ \ENABLE~1", "c:\RabbitMQ\ENABLE~1"}

我设置了以下内容，然后重新安装了服务：

为什么它仍在我的漫游配置文件中查找任何内容？此外，ENABLE~1 看起来不像是一个有效的文件名。

• 我试过吹走我的漫游配置文件数据，RabbitMQ 重新创建文件。
• 我尝试将我的 C:\RabbitMQ\enables_plugins 复制到漫游，同样的事情。
• 反过来尝试，同样的事情。
• 我试过卸载并重新安装服务，同样的事情。

我能够在安装后启用管理 ui，但不能启用 rabbitmq_shovel 并且无法弄清楚问题是什么。

同样，这在安装后有效：

这失败并出现上述错误：

我在 CMD 中以管理员身份运行这些命令。

在 rabbitMq 网络界面中，我有铲子插件。

然而，当我使用它来铲除消息时，显示消息率的图表会上下波动，就好像发生了什么事情一样，但排队的消息保持不变。

当我使用网络界面查看目标队列时，我还可以看到“消息率”发生了变化，但没有任何内容进入排队的消息。

我什至不知道在哪里查找错误，因此不胜感激。

添加：

我不知道要对我的设置添加什么，因为您很可能可以阅读，然后我对 RabbitMQ 不太熟悉。

我有一个死消息队列。即由于某种错误而导致的消息。当我的队列被命名为 myqueue 时，这个队列被命名为 myqueue.dead。在修复了一个错误后，我将所有从死队列中铲到要再次处理的队列中。

在 Web 界面中是“移动消息”按钮。它通常可以工作，但现在不行。

现在我没有看到消息被移动，但是如果我再次快速单击死队列，那么即使排队消息的图表没有改变，“消息率”图表也会迅速出现“消费者确认”，例如红色图表。

在目标中也是如此。它带有很多“交付手册”，即蓝色图表。但它只是快速上升和下降，没有任何反应。

环境：

RabbitMQ 3.7.2 (AMQP 0.9.1)

二郎20.1.7.1

ActiveMQ 5.14.3 (AMQP 1.0)

RabbitMQ 和 ActiveMQ 在同一主机上运行（Debian）

我创建了一个以 AMQP 1.0 作为源 (ActiveMQ) 和 AMQP 0.9.1 作为目标 (RabbitMQ) 的铲子。RabbitMQ 成功连接到 ActiveMQ 队列（我将其视为消费者），但是一旦我在队列 (ActiveMQ) 中发送消息，它会立即断开连接，并且出现匹配错误。

我用动静铲测试过

铲子配置：

铲配置

日志

我想要实现的是内部网络中的 RabbitMQ 客户端与在 Azure 中运行的 Azure 服务总线消费者之间的互操作性。

RabbitMQ 客户端需要发布和订阅，Azure 服务总线消费者也是如此——所以我需要某种“双向代理”。我正在努力实现的图表：

AFAIK，RabbitMQ 代理和 Azure 服务总线都可以执行 AMQP 1.0。我看过rabbit shovel插件，但我认为这只会处理从内部客户端到Azure的消息发布，并且不允许客户端订阅Azure消费者发布的消息？还是我弄错了，铲子可以解决这个问题？

如果铲子不起作用，还有其他方法可以实现吗

我在不同的数据中心有 2 个 RabbitMQ 集群。目前，我们正在将其中一个交换从一只兔子转移到另一只兔子，但现在我们也需要朝另一个方向推进。我们如何在不导致无限循环的情况下实现这一点？

一位同事认为我们可以勾选“添加转发标头”选项，然后使用标头交换进行过滤。但是，添加的标题似乎是嵌套的，我还没有找到与标题匹配的方法？

使用 Spring 和 RabbitMQ，我设置了两个主题交换x和dlx两个队列q和dlq. q绑定到x并且dlq到dlx。dlx被配置为死信交换q。

当一条消息q被拒绝（取消队列）时，它会成功发送到dlx，然后发送到dlq。

现在我使用 shovel-plugin 将死信消息dlq移回q. 只要这次成功处理了消息（ack），这就会成功。

但是，如果这些铲入的消息之一q再次被拒绝，它就会被静默丢弃。我希望它会再次发送到 DLX dlx。是我配置错误还是误解了 DLX 或铲子的概念？