问题标签 [spring-rabbit]

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.

0 投票
6 回答
5878 浏览

spring - spring rabbit XSD 在哪里(rabbit 的架构位置:命名空间)

http://static.springsource.org/spring-amqp/docs/1.0.x/reference/html/提到了rabbit:命名空间,但从未提到架构位置是什么。谷歌搜索(和命名约定)最终得到:

http://www.springframework.org/schema/rabbit/spring-rabbit.xsd

但是这个文件不存在。那么xsd在哪里呢?

0 投票
1 回答
823 浏览

spring - Spring AMQP 模板

请帮我。AmqpTemplateRabbitMQ(AMQP 协议的实现)线程安全的类实例。它可以从多个线程访问吗?谢谢

0 投票
2 回答
5133 浏览

java - RabbitMQ basic.get 和确认

我正在调用:

但是,当我调用 时basicGet,队列中的消息停留在“就绪”状态,而不是“未确认”状态。我希望它们处于未确认状态,以便我可以要么basic.ack它们(从而将它们从队列中丢弃),要么basic.nack它们

0 投票
1 回答
5426 浏览

rabbitmq - RabbitMQ如何在管理工具中判断一个队列是否有Active状态

登录到 Web 管理工具时,具有“活动连接”的队列在队列的详细信息部分显示“活动”状态。请注意,活动连接的概念是我自己的,因为我只是通过 Web 服务 API 从客户端通过 Web 轮询此队列,我没有持久连接。主要问题是如何以编程方式检索此状态?我正在使用 Java (Spring AMQP),但如果需要,我可以深入研究 rabbit java api。

我还查看了 HTTP API,但据我所知,它与 HTTP 管理门户中的“状态:活动”显示没有直接匹配。

0 投票
1 回答
846 浏览

spring-rabbit - 如何处理 spring rabbit 中的连接中断?

如何处理 spring-rabbit 中从我的兔子服务器断开的连接?我需要设置任何特定选项吗?配置如下图:

0 投票
2 回答
6410 浏览

rabbitmq - spring-rabbitmq如何配置心跳

如何配置 spring-rabbitmq 连接工厂

有一个请求的心跳?

0 投票
1 回答
1394 浏览

rabbitmq - RabbitMQ 突然收不到来自 Spring AMQP 的消息

我一直在将我的开发环境从 Linux 转移到 Mac,突然间我面临着奇怪的 RabbitMQ 行为。

我有 Ubuntu 盒子,在上面运行 RabbitMQ 2.8.7-1,我在同一个盒子上做了开发工作。我一直在运行我的测试代码(如下所示),Rabbit 很高兴收到所有消息。

现在我搬到了 Mac 机器(主机 A),我在其中运行带有 Linux 的 VirtualBox(主机 B),在该机器上运行 RabbitMQ,其配置与以前的 Linux 机器相同。我在 Mac 上运行我的开发环境,它在 VM 中调用 Rabbit :)。但是什么也没来,所以我使用 Wireshark 来追踪通信,这似乎还可以:

所以看起来消息已经收到,但可能没有被代理处理?登录客户端也告诉我消息已发布。

我完全不知道从哪里开始解决问题,为什么它以前可以工作而不是现在,问题可能出在哪里?

编辑:好的,我尝试从 RabbitMQ 教程中实现简单的发送器,它看起来像挂在 close() 上,因为应用程序仍在运行并且未到达 close() 之后的代码。

0 投票
1 回答
1696 浏览

java - RabbitMQ 和 Camel:路由因“恢复时丢失消息”而中断

我对 RabbitMQ 和 sprimg-amqp 有一个令人沮丧的问题。我需要从外部进程向队列发送消息(一个 JUnit 类只是为了测试路由是否正常工作)。这是我的 camel-context.xml 文件:

当我使用 maven camel:run 启动它时,它运行良好。交换可用并且还在 RabbitMQ 管理中排队。当我尝试向该 Exchange 发送消息时会出现问题:

消息已正确发送到队列(我可以在日志中看到它们),但引发异常并且路由停止:

那有什么问题?我必须生成消息 ID 的原因是什么?

0 投票
1 回答
2513 浏览

spring - Rabbit Admin 的意外行为

我的印象是 RabbitAdmin

“默认情况下会自动查找 Queue、Exchange 和 Binding 类型的 bean,并代表用户向代理声明它们”

在我看来,如果我已经在代理上声明了多个队列,如果我添加了一个未声明的新队列,管理员将在声明它时遇到问题,抛出:-

RabbitMQ xml 配置:

代码:

这是一个已知问题还是某种配置错误?

0 投票
1 回答
6032 浏览

rabbitmq - Spring rabbit 不允许在缓存连接工厂配置中覆盖默认值:1.1.4 版

我尝试使用 spring amqp 应用程序将 JSON 数据作为消息发送给消费者(用 Ruby 编写)。

我尝试的任何设置都会出现连接重置错误

注意:我删除了默认的来宾用户,并添加了对默认虚拟主机具有相同权限的管理员。

这是配置:

在我的制作人课上

我得到一个

com.rabbitmq.client.PossibleAuthenticationFailureException: 可能是认证失败异常引起

堆栈跟踪显示连接重置

消息消费者如下

更新:似乎更新的用户名和密码设置没有传播,兔子日志显示我的应用程序仍然使用来宾