问题标签 [grails-plugin-rabbitmq]

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 投票
1 回答
380 浏览

grails - 使用带有 rabbitmq-native 插件 (3.4.4) 的 Grails 3.3.2,prefetch=1 的单个消费者在发生异常后停止消费消息

我已经重试设置为true。我的理解是,信息应该不断地不断地传递给消费者。相反,它只是坐在那里不消耗重新排队的消息或任何新消息。我将 com.budjb 和 com.rabbitmq 和 org.springframework.amqp 的日志一直打开到 TRACE 并且没有看到任何断开连接... Heeelppp

应用程序.groovy

消费者:

更新 看来,当 transacted=true 和 autoAck = AutoAck.POST 在 AbstractConsumerContext.groovy 内触发的 txRollback() 正在阻止 basicReject nack 到达 RabbitMQ 服务器。

0 投票
1 回答
44 浏览

grails3 - Grails RabbitMQ 本机:内插凭据上的 AuthenticationFailureException

使用 Grails RabbitMQ-native 插件,在 application.yml 的 Rabbit 连接配置中使用环境变量插值时,插值不起作用:

在硬编码相同的凭据工作时导致 AuthenticationFailureException。

有解决方法吗?我不想将凭据硬编码到我们的 RabbitMQ 实例...