当前位置: 首页 > 知识库问答 >
问题:

如何使用Spring Cloud Stream在RabbitMQ中的队列中添加特性“x-delayed-type:direct”?

宦文柏
2023-03-14

这是我的应用程序属性部分:

Spring云流动兔子绑定。学生输入。消费者交换类型=直接Spring。云流动兔子绑定。学生输入。消费者延迟交换=真

但似乎在RabbitMQ管理页面中,它在我的队列的Args in功能中没有x延迟类型:直接。我引用的是这个Spring Cloud Stream留档:https://docs.spring.io/spring-cloud-stream/docs/Elmhurst.RELEASE/reference/htmlsingle/

我做错了什么?提前感谢:D

共有1个答案

钱稳
2023-03-14

我只是测试了一下,效果很好。

你启用插件了吗?如果没有,您应该在日志中看到这一点。。。

2018-07-09 08:52:04.173错误156-[127.0.0.1:5672]o.s.a.r.c.CachingConnectionFactory:通道关闭:连接错误;协议方法:#方法(回复代码=503,回复文本=命令无效-未知的exchange类型“x-delayed-message”,类id=40,方法id=10)

请参阅插件文档。

另一种可能性是交换已经存在。Exchange配置是不可变的;您将看到这样的消息。。。

2018-07-09 09:04:43.202ERROR 3309 --- [ 127.0.0.1:5672]o. s. a. r. c. CachingConnectionFactory:通道关闭:通道错误;协议方法:#method(report-code=406, report-text=PRECONDITION_FAILED-不等价的arg'type'用于交换'so51244078'在vhost'/'中:接收到"x-delited-mail",但当前为"Direct",class id=40, method-id=10)

在这种情况下,您必须先删除交换。

顺便说一下,您也需要路由密钥;默认情况下,队列将与主题交换通配符绑定。

 类似资料:
  • 有什么方法可以声明惰性加载队列吗?

  • 我花了整整一天的时间来尝试让spring-AMQP示例项目在docker版本的RabbitMQ上运行。我只是在运行标准的rabbitmq Docker。虽然我没有连接问题,但我总是得到与创建队列相关的异常,并且我已经尝试了所有可能的变体,在这一点上。 我尝试在我的配置中声明队列,就像示例项目一样。我尝试显式配置RabbitAdmin。我已经尝试显式配置整个自动配置混乱。我在rabbitmq中创建了

  • 我在 RabbitMQ 中创建新队列时遇到了一些问题。我只创建一个使用者客户端,该客户端将使用来自另一个微服务的消息。 这是我到目前为止所做的。 应用程序属性: 配置类: 和侦听器类: 当我运行这个程序时,我有一条ACCESS_REFUSED消息,但我不知道为什么。我错过了什么吗?? 谢谢

  • 问题内容: 如何通过在alter上输入值来添加该列?作为示例,我想在每行上添加 tempID 的列,该列的值为“ 3” 也许是这样的 但是上面的代码仅用于时间戳,不适用于整数值。提前致谢 问题答案: 您应该查看此https://dev.mysql.com/doc/refman/5.7/en/alter- table.html 对于您的情况,它将类似于

  • 本文向大家介绍如何在jQuery中的特定HTML标签中添加属性?,包括了如何在jQuery中的特定HTML标签中添加属性?的使用技巧和注意事项,需要的朋友参考一下 使用该方法将属性添加到jQuery中的特定HTML标记中。 示例 您可以尝试运行以下代码,以了解如何将属性添加到特定的HTML标签:

  • 我试图实现一个异步GRPC服务器,在该服务器中,每当客户端进行调用时,它都会得到一个不确定的消息流。我通读了官方文件。它没有涵盖我希望为每个RPC保持流打开的场景。本文-https://www.gresearch.co.uk/article/cleares-learnt-from-writing-asynchronous-streaming-grpc-services-in-c/通过将回调处理程序