问题标签 [rabbitmq-shovel]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
spring-rabbit - 通过spring xml创建铲子
使用spring XML,就像我们创建队列,绑定等如下
我们也可以制造铲子吗?
请告诉我。我想自动创建动态铲子。不是手动通过管理插件。
rabbitmq - 如何通过命令行删除rabbitmq铲子
我使用rabbitmqctl set_parameter shovel“MyShovel”创建了铲子......
现在我想删除它,你能告诉我如何使用命令行来实现它。
rabbitmq - RabbitMq Direct reply-to aka Fast Rpc with 2 servers
是否可以配置 2 个 Rmq 服务器以便在它们之间使用直接回复?
例如
RpcClient 连接服务器 1 并调用连接到服务器 2 的 RpcServer。
是否可以铲/联合伪队列amq.rabbitmq.reply-to
提前致谢!
rabbitmq - 消费者如何根据发布者设置的消息的优先级获取消息 RabbitMQ
我已经为单个消费者发布了一些优先级设置的消息(即可以根据消息优先级接收消息的单个消费者)。我想要的是获取这些消息并根据消费者端的消息优先级打印它们。嘿伙计们帮我解决这个问题!
在上面的代码中,我使用线程来传递优先级和消息值,并同时启动两个线程来发布具有不同优先级的消息。我已经在 AMQ Builder 中设置了优先级值。
rabbitmq - RABBITMQ - 应用插件失败
编辑:在系统环境变量中设置 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 铲消息不移动它们
在 rabbitMq 网络界面中,我有铲子插件。
然而,当我使用它来铲除消息时,显示消息率的图表会上下波动,就好像发生了什么事情一样,但排队的消息保持不变。
当我使用网络界面查看目标队列时,我还可以看到“消息率”发生了变化,但没有任何内容进入排队的消息。
我什至不知道在哪里查找错误,因此不胜感激。
添加:
我不知道要对我的设置添加什么,因为您很可能可以阅读,然后我对 RabbitMQ 不太熟悉。
我有一个死消息队列。即由于某种错误而导致的消息。当我的队列被命名为 myqueue 时,这个队列被命名为 myqueue.dead。在修复了一个错误后,我将所有从死队列中铲到要再次处理的队列中。
在 Web 界面中是“移动消息”按钮。它通常可以工作,但现在不行。
现在我没有看到消息被移动,但是如果我再次快速单击死队列,那么即使排队消息的图表没有改变,“消息率”图表也会迅速出现“消费者确认”,例如红色图表。
在目标中也是如此。它带有很多“交付手册”,即蓝色图表。但它只是快速上升和下降,没有任何反应。
rabbitmq - 从 AMQP 1.0 铲到 AMQP 0.9.1 不匹配错误 utf8
环境:
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 服务总线
我想要实现的是内部网络中的 RabbitMQ 客户端与在 Azure 中运行的 Azure 服务总线消费者之间的互操作性。
RabbitMQ 客户端需要发布和订阅,Azure 服务总线消费者也是如此——所以我需要某种“双向代理”。我正在努力实现的图表:
AFAIK,RabbitMQ 代理和 Azure 服务总线都可以执行 AMQP 1.0。我看过rabbit shovel插件,但我认为这只会处理从内部客户端到Azure的消息发布,并且不允许客户端订阅Azure消费者发布的消息?还是我弄错了,铲子可以解决这个问题?
如果铲子不起作用,还有其他方法可以实现吗
rabbitmq - 如何配置 RabbitMQ 双向铲子,避免死循环?
我在不同的数据中心有 2 个 RabbitMQ 集群。目前,我们正在将其中一个交换从一只兔子转移到另一只兔子,但现在我们也需要朝另一个方向推进。我们如何在不导致无限循环的情况下实现这一点?
一位同事认为我们可以勾选“添加转发标头”选项,然后使用标头交换进行过滤。但是,添加的标题似乎是嵌套的,我还没有找到与标题匹配的方法?
java - 从一个队列推到另一个队列后如何拒绝消息?
使用 Spring 和 RabbitMQ,我设置了两个主题交换x
和dlx
两个队列q
和dlq
. q
绑定到x
并且dlq
到dlx
。dlx
被配置为死信交换q
。
当一条消息q
被拒绝(取消队列)时,它会成功发送到dlx
,然后发送到dlq
。
现在我使用 shovel-plugin 将死信消息dlq
移回q
. 只要这次成功处理了消息(ack),这就会成功。
但是,如果这些铲入的消息之一q
再次被拒绝,它就会被静默丢弃。我希望它会再次发送到 DLX dlx
。是我配置错误还是误解了 DLX 或铲子的概念?