在带有amqp的spring-boot中使用基于注释的侦听器来NACK消息的正确异常类型是什么？
在带有amqp的spring-boot中使用基于注释的侦听器来NACK消息的正确异常类型是AmqpRejectAndDontRequeueException。
AmqpRejectAndDontRequeueException是Spring AMQP框架提供的异常类型，用于在消息处理过程中发生错误时，明确地拒绝消息并阻止重新入队。当使用基于注释的侦听器处理消息时，如果需要NACK消息并阻止重新入队，可以抛出AmqpRejectAndDontRequeueException异常。
该异常的使用场景包括但不限于：
- 消息处理过程中发生了无法恢复的错误，需要明确地拒绝消息。
- 遇到了无法处理的消息，需要将其标记为无效并阻止重新入队。
使用AmqpRejectAndDontRequeueException异常可以确保消息被正确地拒绝，并且不会被重新入队。这对于处理无法处理的消息或者避免消息重复处理非常有用。
在腾讯云的产品中，与AMQP相关的产品是消息队列 CMQ（Cloud Message Queue）。CMQ是一种高可用、高可靠、高性能的消息队列服务，可用于构建分布式应用、解耦系统组件、削峰填谷、异步任务处理等场景。您可以通过以下链接了解更多关于腾讯云消息队列 CMQ的信息：消息队列 CMQ产品介绍。
相关·内容
1回答
我是春季AMQP的新手。我有一个应用程序，它是一个生产者，它向另一个作为使用者的应用程序发送消息。
一旦使用者收到消息，我们将对数据进行验证。
，如果数据是正确的，我们必须从队列中删除消息。如果数据不正确，我们必须对数据进行NACK(负确认)，以便在RabbitMQ中重新排队。
我偶然发现
**factory.setDefaultRequeueRejected(false);**(它根本不会请求消息)
**factory.setDefaultRequeueRejected(true);**(当异常发生时，它将请求消息)
但就我的情况而言，我将确认基于验证的信息。那么它应该删除消息。如果NACK
浏览 1提问于2016-09-16得票数 18
回答已采纳
我正在使用KafkaListener，并希望根据消息是否成功处理来控制偏移的提交。为此，我使用了下面的代码，但它在nack(索引、睡眠)上抛出异常：
@KafkaListener(topics="topic-name", groupId="group"){
someMethod(@Header(KafkaHeaders.OFFSET) int offset, Acknowlegement ack, String message){
try{
processMessage(message);
浏览 5提问于2020-03-06得票数 0
回答已采纳
我正在使用spring amqp通过出站网关将我的消息发布到RabbitMQ。我已经在连接工厂上设置了发布者确认，并添加了我的自定义回调侦听器。
问题是我的CorrelationData总是空的，并且我不能在出站网关上添加任何相关数据。这仅适用于出站通道适配器。
对于出站网关，publisher确认还能工作吗？
编辑我的配置如下。我查看了SI代码，是的，出版商确认，是启用的。问题是当我收到一个NACK时我该怎么做？因为出站网关我不需要相关id来处理响应，所以已经有一个线程在监听响应的临时回复队列。
使用带有出站网关的publisher确认到底有什么意义？如果没有响应，或者我的Rabbit节点宕
浏览 1提问于2014-12-16得票数 1
我使用SpringAMQP2.1.6来使用RabbitListener返回Mono<Void>的消息。例如：
@RabbitListener
public Mono<Void> myListener(MyMessage myMessage) {
Mono<Void> mono = myService.doSomething(myMessage);
return mono;
}
阅读，它说：
侦听器容器工厂必须配置为AcknowledgeMode.MANUAL，这样使用者线程就不会破坏消息；相反，异步完成将在异步操作完成时对消息进行包装或na
浏览 0提问于2019-05-21得票数 4
回答已采纳
我正在尝试使用这个教程()来玩弄rabbitmq，我不确定为什么我不能立即得到所有的消息。
代码片段：
Runner.java
package hello;
import java.util.concurrent.TimeUnit;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.boot.CommandLineRunner;
import org.springframework.context.ConfigurableApplicationContext;
imp
浏览 0提问于2018-03-02得票数 0
回答已采纳
我使用rabbitmq从各种输入源(websocket，rest，.)传送消息。敬我的员工。每个工作人员都会在共享交换中监听一组不同的路由密钥。
现在，workerA可能处理"routeA“。当我的输入源向routeA发送一些东西时，workerA会捡起它并消耗它。
但是，如果没有A路线--“消费者”会发生什么呢？在这种情况下，我希望输入源“知道”该请求没有人。因为没有“兔子消费者”在使用这个信息，所以它被丢弃了。(如果行话不准确，很抱歉)据我所知，控制信息(?)处理，这是NotifyReturn() (amqp的戈朗库)开始的地方，这样出版商就可以知道它的消息被丢弃了。
下面是我的代
浏览 4提问于2019-11-26得票数 0
问题是何时向代理发送ACK或NACK帧。说：
ACK用于使用客户端或客户端个人确认来确认来自订阅的消息的消耗。在通过ACK确认消息之前，从这样的订阅接收到的任何消息都不会被视为已被消耗。
“消费”对我来说意味着“在收到和处理之后”。所以我可以想象两种情况。
场景--接收消息后的：
function on_message(message)
message.ack()
heavy_processing(message)
或者消息处理后的场景B：
function on_message(message)
heavy_processing(message)
me
浏览 2提问于2020-02-12得票数 1
回答已采纳
我使用发行者确认和Amqp.outboundAdapter，我想正确地管理异常情况。
根据下列适配器；
如何捕捉网络/连接故障？
如何捕获在ack和nack通道中抛出的异常？
如何为确认配置超时？
// 代码
IntegrationFlows
.from("inputChannel")
.handle(Amqp.outboundAdapter(rabbitTemplate)
.confirmAckChannel(ackCha
浏览 0提问于2019-09-11得票数 0
我正在使用spring-amqp并测试RabbitListener#AcknowledgeMode。
当我设置RabbitListener#AcknowledgeMode#AUTO，时，我通过刺穿RabbitListener中的一个异常来触发nack响应。
当我将defaultRequeueRejected设置为true(它意味着消息将请求)时，由wireshark打包：
最后两位表示这两个属性.
当我将defaultRequeueRejected设置为false(这意味着消息不会请求)时，由wireshark打包：
Requeue应该是false.So，这是wireshark的错
浏览 0提问于2020-01-16得票数 2
回答已采纳
下面是我使用的发行者代码。在将消息从队列中删除之前，它需要ack。应该打印出它从使用者那里接收到Ack或nack (代码的底部)。如果您只是单独运行下面的发布代码(没有同时运行使用者代码)，它假设只是挂起、等待ack或nack (但它没有)，它会打印出一个ack，就像消费者发送了它一样。所以我很困惑我是否有任何部分的代码错误。
对于基本代码，我使用了来自rabbitmq官方教程的代码：
对于ack/nack部分代码，我遵循以下内容：
package main
import (
"log"
"github.com/streadway/amqp"
浏览 2提问于2017-04-18得票数 2
回答已采纳
1回答
我使用RabbitMQ和Spring 来处理传入的JSON消息。
配置的相关部分如下所示：
<amqp:inbound-channel-adapter channel="incomingChannel" queue-names="..."
message-converter="jsonConverter" error-handler="errorHandler"
error-channel="errorChannel" />
我使用Jackson Databind作为JSON转换
浏览 5提问于2014-02-26得票数 6
回答已采纳
我是的新手，也许这个问题微不足道。我正在查看从stdin创建RabbitMq消息的示例(RabbitMq)：
<int-stream:stdin-channel-adapter id="consoleIn"
channel="toRabbit">
<int:poller fixed-delay="1000" max-messages-per-poll="1" />
</int-stream:stdin-channel-adapter>
<int:channel id=
浏览 1提问于2015-11-13得票数 1
回答已采纳
我使用spring boot和spring-amqp以及基于注解的监听器来使用rabbitmq代理的消息。我有一个spring组件，它包含如下方法：
@RabbitListener(queues = "tasks")
public void receiveMessage(@Payload Task task) {...}
在成功执行receiveMessage(...)之后，我使用AUTO模式来确认消息。如果我检测到一个特殊的错误，我会抛出AmqpRejectAndDontRequeueException把这个消息放到一个配置好的死信队列中。现在，我只需要nack一条消
浏览 25提问于2016-08-30得票数 1
回答已采纳
1回答
在某些有意发生的情况下，我使用了一些异常来拒绝消息，但是在控制台中显示了异常，乍一看，这看起来不太好。
如何在控制台/文件上登录时隐藏特定的异常？
我用的是弹簧引导和默认的记录器！
public static class UndispatchException extends
AmqpRejectAndDontRequeueException{
public UndispatchException() {
super("Dispatch still looking for a driver");
}
}
在这里，李斯特
@Ra
浏览 2提问于2018-05-15得票数 2
回答已采纳
1回答
我正在编写一个包含publisher确认的go程序，并且我希望验证消息何时可以传递/不被传递给代理时的行为。
我是通过一个建立队列的集成测试来完成这个任务的，并要求我的系统代码发送到那个队列名。验证publisher ack的行为没有问题，但我不能引发导致publisher nack的情况。
我尝试用以下代码向不存在的队列发送消息：
connection, err := amqp.Dial("amqp://localhost")
if err != nil {
panic(err)
}
defer connection.Close()
channel, err := c
浏览 3提问于2015-03-05得票数 3
我们正在使用spring-amqp库来消费来自RabbitMQ的消息，有时当我们对消息进行打包时，我们会遇到以下异常：
org.springframework.amqp.AmqpException: PublisherCallbackChannel is closed
at org.springframework.amqp.rabbit.connection.CachingConnectionFactory$CachedChannelInvocationHandler.invoke(CachingConnectionFactory.java:908)
at com.sun.proxy.
浏览 0提问于2018-05-25得票数 0
1回答
我在生产中使用rabbitmq，在集成测试中使用QPid。我需要编写集成测试，以验证无法路由的消息是否调用了返回通道。我设置了mandatory=true和解除绑定的队列和交换，但是调用的是nack通道(抛出NackedAmqpMessageException)而不是返回通道。从不调用返回通道。 我使用Spring AMQP和Spring Boot + Spring Integration。如何在测试中产生返回通道用例？ 我使用以下版本： Qpid 7.1.4
Amqp client 5.4.3
Spring Integration 5.1.9
Spring Boot 2.1.2 谢谢。
浏览 11提问于2020-04-10得票数 0
我想做：
从web服务接收消息
向兔子发送xml消息
验证xml到xsd ->启动异常(验证不正确)
将自定义错误消息返回到web服务
步骤1:从web服务接收消息->结果确定
<ws:inbound-gateway id="ws-inbound-gateway"
request-channel="requestChannel" reply-channel="replyChannel" reply-timeout="300000"
error-channel
浏览 3提问于2017-07-26得票数 0
回答已采纳
当消费者在消息处理期间并且在手动ack工作之前抛出异常republishToDlq时，但是原始队列消息总是处于nack状态。 环境 Spring Boot：2.1.11.RELEASE Spring Cloud：Greenwich.SR4 Spring Cloud Stream：Fishtown.SR4 spring-cloud-stream-binder-rabbit：2.1.4.RELEASE Yaml配置 spring:
cloud:
stream:
bindings:
input:
binder: rabbit
浏览 11提问于2020-01-17得票数 0
回答已采纳
我有一个RabbitMQ触发的Spring批处理应用程序。
我需要在异常上消息。但是，Spring不会在run方法之外抛出异常。因此，我需要nack在SkipListener中的消息。我已经设法将消息标记作为一个JobParameter，JobParameter，但由于它不是Serializable.，所以无法将频道作为一个JobParameter发送
是否有任何方法将通道传递给批处理过程或任何其他错误处理方法？
这是我现在的一个例子。
MessageConsumer.java
import com.project.common.dto.DataImportStartDto;
import c
浏览 4提问于2021-05-31得票数 1
回答已采纳
我要重试一次，使之成为真。我的理解是，信息应该一次又一次地传递给消费者。相反，它只是坐在那里，不使用请求的消息或任何新消息。我打开了com.budjb、com.rabbitmq和org.springframework.amqp的日志记录来跟踪，没有发现任何不连接的情况.希尔普
application.groovy
rabbitmq {
uri = new URI(System.env.CLOUDAMQP_URL ?: "amqp://test:test@localhost/test")
username = uri.userInfo.split(":")[0]
浏览 3提问于2018-04-24得票数 0
1回答
超时后重新发送消息
、、、
我有一个放在Spring AMQP中的对象列表。对象来自控制器。有一个处理这些对象的服务。并且此服务可能会因OutOfMemoryException而崩溃。因此，我运行了该应用程序的几个实例。 有一个问题:当服务崩溃时，我会丢失接收到的消息。我看过关于NACK的报道。并且可以在出现异常或RuntimeException的情况下使用它。但是我的服务错误地崩溃了。因此，我不能发送NACK。是否可以在AMQP中设置超时，在超时之后，如果我没有确认较早到达的消息，将再次发送消息？ 下面是我写的代码： public class Exchanges {
public static final S
浏览 14提问于2019-12-06得票数 0
回答已采纳
我正在尝试用一个兔子绑定器来配置一个spring云流应用程序。
spring cloud stream : 3.1.4
spring cloud stream rabbit binder : 3.1.4
spring version : 2.5.5
下面是我的配置：
spring:
cloud:
stream:
rabbit:
bindings:
listen-in-0:
consumer:
queueNameGroupOnly: true
enable-
浏览 2提问于2021-10-27得票数 1
回答已采纳
春季卡夫卡版本- 2.8.5
```@KafkaListener
consumeMessages(@Payload List<String> messages,Ack ack)
{
//process records in separate Thread and acknowledge
// Thread is not available nack it after 2 seconds
}```
Nack记录应在KafkaListener中的2秒后重新处理。但是，跳过的记录不是由KafkaListener处理的。重新启动Spring应用程序
浏览 2提问于2022-07-08得票数 0
我有一个spring的amqp应用程序，我想使用，但我似乎不知道如何让它来注册我的听众服务。这是我的基于注释的配置文件。
package com.jerry.configuration;
import org.springframework.amqp.core.AmqpAdmin;
import org.springframework.amqp.core.Queue;
import org.springframework.amqp.rabbit.connection.CachingConnectionFactory;
import org.springframework.amqp.rabbi
浏览 1提问于2017-12-20得票数 0
回答已采纳
1回答
我有一个定义2 JMSListeners的类。1侦听器用于客户端从使用JMS的服务器接收的消息MyMessage1。另一个是MyMessage2，它是由另一个程序生成的，不使用JMS (不是java程序)。当我试图接收这条消息时，我似乎得到了一些JMS侦听器异常。尽管有效负载表明它是一个GenericMessage，但是它没有为它指定完整的MyMessage包名，但它似乎正在使用一个MyMessage2并试图将它转换成一个MyMessage2。
GenericMessage到底是什么？这是否表明发件人没有正确标识邮件的类型？我是否需要以某种方式为通用消息定义一个JMSListener，并手动序
浏览 2提问于2017-02-07得票数 0
回答已采纳
我有一个db查询，它得到一个ID列表。
我使用拆分器将它们分割成一个带有任务执行器的通道。
然后我为每个Id发布amqp消息
要求:在我进入下一步之前，我需要确认所有消息都已经发布了。
因此，我在消息ack通道之后添加了一个聚合器。
问题:对于较少数量的is (可能少于3000条记录)，该解决方案正在按预期工作。但是对于更多的ID，聚合器会被困住等待。
已发布消息的数量总是正确的。因此，我在db update下面添加了代码，使其在确认通道之后有一个计数器，并且计数小于较大ID列表的ID数。
<!-- service activator query database t
浏览 1提问于2016-09-21得票数 1
回答已采纳
我正在尝试使用Qpid JMS和ProtonJ (AMQP1.0)发送和接收消息，但无法接收TextMessage。异常说明它不能将JmsBytesMessage强制转换为TextMessage
org.apache.qpid.jms.message.JmsBytesMessage cannot be cast to javax.jms.TextMessage
即使尝试将消息作为JmsTextMessage接收，也会导致：
org.apache.qpid.jms.message.JmsBytesMessage cannot be cast to org.apache.qpid.jms.mess
浏览 21提问于2018-12-19得票数 1
回答已采纳
2回答
我一直在尝试Spring AMQP。我有几个问题：
我想知道什么是出版商退货，它与出版商确认有什么不同。据我所知，我们有一个发布者确认回调来检查ack的状态。现在，我查看了Spring AMQP和Rabbit MQ中的文档。在这方面并没有真正找到或理解太多。
还有，为什么如果尝试将消息发送到不存在的队列，我既得不到任何类型的确认(ack/nack )，也得不到任何错误。对于非确认，有没有setTimeouts的方法？
浏览 0提问于2018-05-22得票数 4
My场景：向兔子代理发布两条消息，在处理第一条消息时会发生未处理的异常。
My的问题：，为什么消息在代理中仍然是Unack的，因此为什么第二条消息不被排队和处理？
一些信息:SpringIntegration4.2.4正在使用SpringAMQP1.5.4和SpringIntegration4.2.4。(请参阅下面的代码)我已经设置了一个死信交换，它正在按预期工作(即，当我插入一条消息时，它将被转发到DLX，在那里它将过期。然后将其转发到主Exchange)。
我想要的：，我希望未处理的异常(即被SimpleMessageListenerContainer捕获的异常)导致amqp消息是Nack
浏览 3提问于2016-02-25得票数 1
回答已采纳
我试图找出处理服务中可能发生的错误的最佳方法，该服务是在聚合的组超时发生后调用的，该服务模拟了与满足releaseExpression相同的流。
这是我的设置：
我有一个AmqpInboundChannelAdapter，它接收消息并将它们发送到我的聚合器。
当满足releaseExpression时，在groupTimeout过期之前，如果在groupTimeout中抛出异常，消息将被发送到该MessageGroup中所有消息的死信队列中。(下面的例子中有10条信息，仅用于说明性目的)这是我所期望的。
如果没有满足我的releaseExpression，但groupTimeout已经满足，并
浏览 0提问于2019-04-02得票数 2
回答已采纳
我正在开发我的后端应用程序GCM服务器，根据我对文档的理解，我的应用服务器发送的每条下游消息都应该收到ACK (如果成功的话)，如果有问题的话应该是NACK。我能够成功地发送下游消息，因为我的应用程序正在接收它们，但我从来没有任何ACK。我尝试通过在发送下游消息时输入虚假的注册ID来测试NACK，但仍然一无所获。
我正在使用smack库，我尝试用这两个库发送下游消息
XMPPTCPConnection.send()
XMPPTCPConnection.sendStanzaWithResponseCallback()
也不给任何回应。我是不是遗漏了什么？
浏览 2提问于2015-11-29得票数 2
回答已采纳
1回答
我正在尝试使用RPC队列来发送和接收消息。问题是我设置了一个setReplyTimeout值。当这种情况发生时，我会在超时后收到一个"org.springframework.amqp.AmqpRejectAndDontRequeueException:回复“。我在传入队列上设置了一个DLQ，但是当spring试图在其队列上返回自动创建的消息时，似乎会收到异常。因此，当将消息发送回生产者时，我如何处理异常？理想情况下，我希望在发送给生产者发送到DLQ时获得异常的任何消息。
我在用
@RabbitListener(queues = QueueConfig.QUEUE_ALL, contai
浏览 0提问于2018-12-12得票数 0
回答已采纳
我想使用DSL重复
来自示例的配置：
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:int="http://www.springframework.org/schema/integration"
xmlns:int-
浏览 2提问于2019-08-27得票数 0
回答已采纳
我目前正在试验通过message进行通信时可能发生的失败场景。目的是评估如何使这种交流更具弹性。
特别是，我希望在中发送消息时触发nack (不确认)确认。为此，我通过Spring的RabbitTemplate.send向一个不存在的交换发送消息。在通过RabbitTemplate.setConfirmCallback提供的回调中，我通过将消息重发到现有的交换(模拟我处理nack原因)来处理ack=false确认。
下面提供了一个样例类和相关的测试，完整的示例项目可以在中找到。我使用了RabbitMQ 3.6和Spring /AMQP2.0.2。
在运行测试时，将按预期使用ack=false调
浏览 2提问于2018-05-29得票数 1
回答已采纳
我有一个来自单个RabbitMQ队列的Go应用程序处理事件。我使用 RabbitMQ客户端库。
Go应用程序在2-3秒内处理每条消息。如果我从内存中给出消息，可以并行地处理1000条甚至更多的消息。但是，不幸的是，RabbitMQ性能更差。因此，我想更快地使用队列中的消息。
因此，问题是:如何使用github.com/streadway/amqp以最有效的方式使用消息
据我所知，有两种方法：
定高预取
。
使用单一的消费价格
示例代码：
conn, err := amqp.Dial("amqp://guest:guest@localhost:5672/")
fail
浏览 2提问于2019-08-06得票数 1
回答已采纳
问题：I正在从MessageListener接口impl迁移到@RabbitListener。我有这样的逻辑:在由几个类继承的MessageListener上进行“预”和“后”消息处理。
示例：
public AbstractMessageListener implements MessageListener {
@Override
public void onMessage(Message message) {
//do some pre message processing
process(Message message);
浏览 5提问于2015-12-29得票数 12
回答已采纳
4回答
我需要为新项目选择一个新的队列代理。
这一次，我需要一个支持发布/订阅的可伸缩队列，并且必须保持消息排序。
我读到亚历克西斯的评论:他写道：
事实上，我们认为RabbitMQ提供了比卡夫卡更强大的秩序
我在rabbitmq文档中阅读了消息排序部分：
“消息可以使用具有请求参数(basic.recover、basic.reject和basic.nack)的AMQP方法返回到队列，或者由于通道关闭，同时保存未确认的2.7.0版本和更高版本，如果队列有多个订阅者，单个使用者仍然可以观察消息的无序。这是由于其他可能请求消息的订阅者的行为。从队列的角度来看，消息总是以发布顺序保存。”
如
浏览 10提问于2014-01-26得票数 84
回答已采纳
我正在使用Alpakka AMQP库()来处理反应流中的RabbitMQ消息，并将它们转储到Kafka中。
我们使用的是Avro和Schema Registry，因此格式错误的消息无法通过验证，需要根据具体情况进行处理。我们想要的行为是应用程序死亡，并在30秒-1分钟后重启，在此期间，我们可以使用UI将消息从队列中拉出，以查看它出了什么问题。
由于某些原因，我的nack()似乎没有释放回消息，它停留在Unacked状态，在释放之前无法查看。如何做到这一点？我将包含我的代码片段：
Flow[CommittableIncomingMessage]
.map { msg =>
浏览 5提问于2018-08-09得票数 1
回答已采纳
1回答
确切的用法如下：
@Slf4j
public class Client<E, Key> {
@Getter @NonNull private final UpdateListener<E, Key> updateListener;
@NonNull private final SubscriptionFactory subscriptionFactory;
@NonNull private final Map<Key, Instant> updatedRegistry = new ConcurrentHashMap<&g
浏览 1提问于2015-04-28得票数 1
回答已采纳
我从RabbitMq服务器上得到了这个错误
服务器关闭的通道: 406 (前提-失败)，带有消息"PRECONDITION_FAILED -未知传递标记80“
之所以会发生这种情况，是因为连接在使用者任务期间丢失，而在最后，当消息被加/捕获时，我会得到这个错误，因为我无法在与我所得到的消息不同的信道上插入一个消息。
下面是RabbitMq连接的代码
async connect({ prefetch = 1, queueName }) {
this.queueName = queueName;
console.log(`[AMQP][${this.queueNam
浏览 14提问于2021-07-01得票数 0
回答已采纳
如果我正确理解AMQP：
在将消息(传递)推送给使用者之后，服务器等待其ACK，如果当消息到达其TTL时未收到ACK，则该消息将被丢弃。
我想要的是当ACK在一段时间后没有被接收时，消息被请求，我怎么做呢？
而且我还需要请求最多3次信息。我知道我可以在客户端通过保持一个计数器并在计数器到达3时拒绝消息(NACK)来做到这一点，但是这能在服务器端完成吗？
浏览 3提问于2015-10-27得票数 0
回答已采纳
我是春天的新手-amqp。我正在尝试手动确认消息，而不是使用自动密码。
我看到最后一条信息正在管理控制台中被解压缩。
，但是队列是空的。
--一旦我停止服务器，最后一条消息就被确认了。如何处理这个问题，以及如何在日志中打印消息id/信息(未被确认).
这是我实现的代码。
RabbitConfig.java：
公共类RabbitMQConfig {
final static String queueName = "spring-boot";
@Bean
Queue queue() {
return new Queue(queueName, true,false,fals
浏览 1提问于2016-11-27得票数 0
回答已采纳
我正在做一个Spring Boot项目，通过Spring AMQP使用RabbitMQ。我们希望能够在消息发布被NACK时测试我们的应用程序的行为(特别是当PublisherConfirmCallback#confirm的ack参数为false时)。然而，我们很难在集成测试中设置这个场景(即，在应用程序运行的情况下，而不是在单元测试中)。
为了清楚起见，我们测试的是发布者的确认，而不是消费者的确认。
我们知道可以使用RabbitTemplate的execute方法访问通道，但是我们的RabbitMQ是自动确认的，所以在执行通道回调时消息已经消失了。我们认为我们可以在运行时禁用自动确认(这样就不
浏览 2提问于2016-02-09得票数 8
1回答
我想我在这里遗漏了一些东西。我试图创建一个简单的兔子列表器，它可以接受自定义对象作为消息类型。现在按照医生的说法
在1.6之前的版本中，转换JSON的类型信息必须在消息头中提供，或者需要定制的ClassMapper。从版本1.6开始，如果没有类型信息头，则可以从目标方法参数推断类型。
我在仪表板中使用兔子mq adm手动地将消息放入队列，得到的错误如下
Caused by: org.springframework.messaging.converter.MessageConversionException: Cannot convert from [[B] to [com.example.Cu
浏览 1提问于2017-01-28得票数 19
回答已采纳
您好，我正在使用Spring Boot的@kafkaListener。我正在消费一批消息。我正在尝试使用Acknowledgment中的nack()方法，但看起来Spring Boot 2.1.8不支持nack()方法。 Spring Boot 2.1.8中有没有像nack()这样的特性 我想抛出一个失败记录的异常，并在下一个poll()中重播剩余的记录。我如何在Spring Boot 2.1.8中实现这一点。我可以使用SeekToCurrentBatchErrorHandler吗？多么?
浏览 447提问于2021-09-21得票数 0
我试图记录在RabbitMQ中发送消息时发生的任何信息或异常，因为我试图在现有的连接工厂中添加ConnectionListener。
kRabbitTemplate.getConnectionFactory().addConnectionListener(new ConnectionListener() {
@Override
public void onCreate(Connection connection) {
System.out.println("Connection Created");
浏览 4提问于2021-03-31得票数 0
回答已采纳
我们有这样的场景，消息从Amqp队列中拉出并写入我们的数据库-但是，在计划的数据库批处理运行期间，数据库不可用，我们无法写入，因此我们希望消息在这些窗口期间保留在队列中。 我正在尝试确定处理此问题的最佳方法--只需在@RabbitListener方法中抛出一个异常，以便(重复地)对消息进行重新排队，或者使用Spring调度程序尝试停止/启动侦听器(我看到SimpleMessageListenerContainer有停止/启动方法)。 对于最好的(或更好的)方法有什么建议吗？
浏览 33提问于2019-05-04得票数 1
回答已采纳
我们使用Stream(3.0.7版) StreamListener来使用Google订阅主题A中的“A.SUB”。我们有一个要求暂停消费从PubSub，我看到以下选项的优先顺序，我没有确切的想法如何实现选项1和2。谁能分享这些想法吗？
添加另一个Pubsub主题'B‘并发布’暂停‘事件消息以暂停或’恢复‘事件消息恢复，在订阅'A.SUB’上的停止/启动计票器看到‘暂停/恢复’有任何方法来实现这一点吗？
根据时间窗口暂停订阅，比如从上午12点到早上6点？有什么方法可以指定某个CRON表达式吗？
使用来自“A.SUB”的消息，并在12点到6点之间发送na
浏览 3提问于2021-03-07得票数 0
回答已采纳
我正在尝试创建一个简单的spring引导应用程序，它可以“生成”消息到一个rabbitmq交换/队列，以及另一个“消费”这些消息的示例spring引导应用程序。所以我有两个应用程序(或者微服务，如果你愿意的话)。1)“生产者”微型服务- 2)“消费者”微型服务
“生产者”有两个域对象。Foo和Bar应该转换为json并发送到rabbitmq。“使用者”应该分别接收和转换json消息为域Foo和Bar。由于某种原因，我无法完成这个简单的任务。这方面的例子不多。对于消息转换器，我想使用org.springframework.messaging.converter.MappingJackson2Me
浏览 2提问于2015-06-11得票数 12
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
