Spring AMQP恢复程序不能与SimpleMessageListenerContainer配合使用
Spring AMQP是一个用于构建消息驱动的应用程序的框架，它基于AMQP（Advanced Message Queuing Protocol）协议。Spring AMQP提供了一套简单易用的API，用于发送和接收消息，并提供了与消息队列的集成。
SimpleMessageListenerContainer是Spring AMQP提供的一个消息监听容器，用于接收和处理消息。它负责从消息队列中获取消息，并将消息传递给注册的消息监听器进行处理。
然而，Spring AMQP的恢复程序（recovery）功能与SimpleMessageListenerContainer不兼容。恢复程序是在消息处理过程中发生异常时，尝试重新发送消息或进行其他处理的机制。它通常用于确保消息的可靠性传递。
由于SimpleMessageListenerContainer是一个异步的消息监听容器，它无法直接支持恢复程序的功能。如果需要在消息处理过程中使用恢复程序，可以考虑使用其他的消息监听容器，如DirectMessageListenerContainer或SimpleRabbitListenerContainer。
DirectMessageListenerContainer是Spring AMQP提供的另一个消息监听容器，它与SimpleMessageListenerContainer类似，但支持恢复程序功能。它可以通过设置恢复程序来处理消息处理过程中的异常情况。
另外，Spring AMQP还提供了一些其他的功能和特性，如消息确认机制、消息转换器、消息路由等。这些功能可以根据具体的业务需求进行配置和使用。
腾讯云提供了一系列与消息队列相关的产品和服务，如消息队列 CMQ、消息队列 CKafka 等。这些产品可以帮助用户构建可靠的消息驱动应用程序，并提供高可用性和可扩展性的消息队列服务。
更多关于腾讯云消息队列产品的信息，可以访问以下链接：
请注意，以上答案仅供参考，具体的解决方案和产品选择应根据实际需求和情况进行评估和决策。
相关·内容
我尝试用弹簧引导连接到RabbitMQ。连接应该总是重新启动/重试连接。在一个致命的异常之后，我在重新连接时遇到了问题。应用程序永远不能断开连接，也不能无限期地重试以获得连接。
@Bean
public IntegrationFlow flow() {
final SimpleMessageListenerContainer listenerContainer = new SimpleMessageListenerContainer(getConnectionFactory());
listenerContainer.setQueues(getQueu
浏览 11提问于2017-05-03得票数 10
实际上，我正在尝试使用兔子mq实现故障转移重传器功能。
因此，我需要从队列中得到一条消息并处理它。如果有任何问题发生，那么消息需要再重试3次。
有人能帮我解决这个问题吗？
这是我的密码
POJO
package com.poc.failoverretryer.model;
import java.io.Serializable;
public class User implements Serializable {
private String firstname;
private String lastname;
private String dob;
浏览 3提问于2020-05-07得票数 0
回答已采纳
我使用Java 1.4.0和‘spring starter’连接到rabbitMq。消息生产者、消费者和rabbitMq服务器都在我的control.Things下工作了几个月。但突然间，我的消费者停了下来，例外情况如下。因为我只产生了总是有效的信息，所以我不知道哪里出了问题。
但这导致我的侦听器容器关闭。因此，我的消息处理停止了，我不得不手动重新启动我的消息使用者程序。
所以我的问题是：：
在任何意想不到的情况下，我们能避免监听器容器的完全关闭吗？
是否有可能优雅地丢弃这样的消息并保持侦听器容器存活？
如果没有，那么有什么方法可以检查我所有的侦听器容器是否都在运行，如果我发现它们
浏览 15提问于2017-02-28得票数 4
我正在使用来自几个服务器的AmqpTemplate.sendAndReceive功能，它可以工作，并且在rabbitmq重新启动或网络问题之后重新连接工作。
它工作了几个星期，但是突然间，我的一个服务器对每个sendAndReceive调用都超时了，rabbitmq正在接收消息，并且正在处理它，但是sendAndReceive没有得到响应(回复超时设置为60秒，处理消息只需几秒钟)。其他服务器在同一时间使用相同的代码和使用相同的队列。
只有在我重新启动服务器上的服务之后，服务器才返回工作。
我认为这是一些重新连接的问题(即使成功地发送到rabbitmq的消息)，也许AmqpTemplate响应
浏览 0提问于2015-06-09得票数 1
回答已采纳
我正在使用springs SimpleMessageListenerContainer来使用RabbitMQ队列中的消息。一切正常，但是当一个无效的消息被发送到队列时(例如无效的json)，监听器就会中止，关闭工作进程，不再接受任何进一步的消息。
是否可以将其配置为丢弃损坏的消息并继续侦听更多消息？
我使用的是sprint-rabbit 1.6.1.RELEASE.jar
我的配置如下所示：
@Bean
public SimpleMessageListenerContainer container(ConnectionFactory connectionFactory,
浏览 2提问于2016-09-01得票数 3
回答已采纳
我有运行服务器A的RabbitMQ和服务器B中的rabbitMQ的使用者，我使用的是spring，这是我的配置。
@Bean
public Queue queue() {
return new Queue(queueName, true);
}
@Bean
public TopicExchange exchange() {
return new TopicExchange(topicExchangeName);
}
@Bean
Binding binding(Queue queue, TopicExchange exchange) {
r
浏览 6提问于2020-03-04得票数 2
回答已采纳
当我停止rabbitmq服务器时，将抛出以下异常：
org.springframework.amqp.AmqpConnectException: java.net.ConnectException: Connection refused: connect
at org.springframework.amqp.rabbit.support.RabbitExceptionTranslator.convertRabbitAccessException(RabbitExceptionTranslator.java:62) ~[spring-rabbit-1.6.6.RELEASE.jar:n
浏览 0提问于2017-06-01得票数 3
4回答
这是我的代码片段。
用于配置的MQConfiguration类
@Configuration公共类MQConfiguration { @Bean公共接收器(){返回新接收器()；}
处理接收消息的Receiver类
@RabbitListener(queues = "testMQ")公共类接收器{ @RabbitHandler公共空接收(Message msg){ System.out.println(msg.toString())；}
下面是我发送给RabbitMQ的JSON消息
{ "id"：1，"name"："My Na
浏览 7提问于2017-02-28得票数 9
当我的事务标记为回滚时，我不希望SimpleMessageListenerContainer继续使用这些消息。
我没有在配置文件中添加listener-container并试图重新抛出AmqpRejectAndDontRequeueException。它不起作用。这是我的代码库：
@Transactional
public class MySecondService {
@Resource
private MySecondRepository mySecondRepository;
@Transactional(propagation = Propagation.
浏览 2提问于2016-10-18得票数 0
回答已采纳
1回答
我的spring boot应用程序抛出连接超时错误，并且它永远无法连接。我看到的另一个有趣的问题是，它永远不会获得spring应用程序属性中定义的连接超时属性。
org.springframework.amqp.AmqpTimeoutException: java.util.concurrent.TimeoutException
at org.springframework.amqp.rabbit.support.RabbitExceptionTranslator.convertRabbitAccessException(RabbitExceptionTranslator.java
浏览 8提问于2017-07-28得票数 2
回答已采纳
我试图在rabbitMQ的帮助下，使用nexmo将调用入站特性集成到我的spring项目中。但我不断地得到下面的例外
[WARN ] 2021-01-26 14:52:26.913 [org.springframework.amqp.rabbit.config.ListenerContainerFactoryBean#6-9] ConditionalRejectingErrorHandler - Execution of Rabbit message listener failed.
org.springframework.amqp.rabbit.listener.exception.Li
浏览 7提问于2021-01-26得票数 2
回答已采纳
1回答
在某些有意发生的情况下，我使用了一些异常来拒绝消息，但是在控制台中显示了异常，乍一看，这看起来不太好。
如何在控制台/文件上登录时隐藏特定的异常？
我用的是弹簧引导和默认的记录器！
public static class UndispatchException extends
AmqpRejectAndDontRequeueException{
public UndispatchException() {
super("Dispatch still looking for a driver");
}
}
在这里，李斯特
@Ra
浏览 2提问于2018-05-15得票数 2
回答已采纳
我在java中为rabbitmq消费者使用spring-rabbit 1.7.1库。我有7个消费者在运行，同样的服务器也是生产者。突然，消费者停止使用消息，并在我重新启动它们时恢复。没有异常，线程转储如下：
SimpleAsyncTaskExecutor-1" #77 prio=5 os_prio=0 tid=0x00007f497ef34800 nid=0x4e93 waiting on condition [0x00007f490cee6000]
java.lang.Thread.State: TIMED_WAITING (parking)
at
浏览 154提问于2018-09-26得票数 0
当可用的RabbitMq服务器向Rabbitmq生成一些消息并使用该消息时，如果队列中没有消息，则该消息将以Queuename和Listener.but为基础。
我的代码如下所示
<bean id="rabbitListenerContainerFactory" class="org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory">
<property name="connectionFactory" ref=
浏览 9提问于2017-12-12得票数 0
3回答
我正在创建一个spring引导应用程序，用于侦听兔子队列，并将消息转发到Kafka流。我正在尝试@Autowire一个Kafka配置类，但我得到了NullPointerException，更令人惊讶的是，当我列出所有spring管理的bean，然后它给出了我要尝试的@Autowire类的对象名称时。我不知道我错过了哪里。
入门课程：
@SpringBootApplication
@ComponentScan(basePackages = {"com.example.demo.service","com.example.demo.configuration"})
浏览 14提问于2021-02-20得票数 0
1回答
在消费者类上创建，以使用来自rabbitMQ图形用户界面的消息。 但是当我从rabbitMQ图形用户界面发布任何消息时，它给出的错误类找不到。并且控制台上不断打印错误。 问题可能是rabbitGUI以字节的形式发送消息，我正在尝试以字符串的形式接收它。 我想调用基于消息体的特定方法。 @Component
@RabbitListener(queues = {"#{addNeRangeQueue.name}"})
public class consumerController {
@RabbitHandler
public void receive(Stri
浏览 100提问于2020-09-10得票数 0
回答已采纳
我试图在Spring中使用rabbitMQ中的Camel，方法如下：
camel-context.xml：
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://www.spri
浏览 2提问于2020-10-30得票数 2
回答已采纳
我试图在spring boot应用程序中设置死信队列，但当我抛出AmqpRejectAndDontRequeueException时，它在控制台中打印整个堆栈跟踪，这是我不想要的。有没有更好的方法呢？ 我试图捕捉这个异常，但是在那个死信队列停止工作之后。 2019-06-25 17:26:33.221 WARN 19812 --- [ntContainer#0-1] s.a.r.l.ConditionalRejectingErrorHandler : Execution of Rabbit message listener failed.
org.springframework.amqp
浏览 46提问于2019-06-26得票数 1
->这是我第一次尝试JMS，我创建了一个消费者类来消费来自rabbitMQ图形用户界面的消息。->，但当我从rabbitMQ图形用户界面发布任何消息时，它给出的错误类没有找到。并且控制台上不断打印错误。 @Component
@RabbitListener(queues = {"#{addNeRangeQueue.name}"})
public class consumerController {
@RabbitHandler
public void receive(String message) {
System.out.pr
浏览 36提问于2020-09-08得票数 0
1回答
我需要配置我的应用程序，以发送和消费消息从//到一个队列上的阳极服务器上。我在my application.properties中有以下配置：
spring.rabbitmq.host=amqp://cloudamqp.com/...
spring.rabbitmq.port=5672
spring.rabbitmq.username=jpkszgmu
spring.rabbitmq.password=***********************
和我的控制器：
@Autowired
private RabbitTemplate rabbitTemplate;
@RequestMappin
浏览 2提问于2017-04-18得票数 1
回答已采纳
当我向RabbitMQ发送消息时，它会抛出一个AmqpException for循环： org.springframework.amqp.rabbit.listener.exception.ListenerExecutionFailedException
: Listener method 'no match' threw exception
at org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(Messagi
浏览 48提问于2019-01-31得票数 7
回答已采纳
我有一个简单的Spring应用程序，其中我为RabbitMQ设置了以下设置(spring starter版本为2.7.0)：
spring:
rabbitmq:
host: localhost
port: 5672
virtual-host: my_host
username: admin
password: password
template:
retry:
enabled: true
initial-interval: 3s
max-interval: 10s
m
浏览 23提问于2022-07-05得票数 0
回答已采纳
1回答
抛出异常时，消息不会进入死信队列
、、、、
我有一个应用程序，在这个应用程序中，我必须在特定情况下将消息移动到DLQ (死信队列)，但在第一个消息中，异常会被抛出，但它会忽略max-attempts:2值，并且我可以看到4次异常消息，并且该消息没有发送到DLQ。 正如在spring cloud stream docs中提到的，抛出异常时，消息应该发送给DLQ。当我尝试发送另一条消息时，我一直在控制台日志中收到一个不同的异常，直到我重新启动应用程序以再次获得第一条消息，但现在该消息被发送到DLQ。 我尝试使用.onErrorContinue，在这种情况下，我的应用程序不会在第一条消息上中断，但消息不会发送到DLQ。 编辑： 在sprin
浏览 169提问于2021-10-18得票数 0
我有一个spring引导项目，在这个项目中，我试图与一个rabbitmq服务器集成，这样我就可以将消息发布到/从队列中读取。
以下是我的rabbitmq配置(编辑后只显示相关细节)：
@Configuration
@ConfigurationProperties(prefix="rabbit")
public class RabbitConfig {
private String queue;
@Bean
Queue queue() {
return new Queue(queue, durable);
}
@Bean
浏览 20提问于2017-08-22得票数 3
回答已采纳
我使用spring 1.5.9 message和spring Edgware.SR1将消息从一个应用程序发送到RabbitMQ，然后以这种方式检索消息：
发送信息：
public interface EventNotificationChannel {
@Output
MessageChannel moneyTransferredChannel();
}
@Slf4j
@RestController
public class TransferController {
private final MessageChannel channel;
public
浏览 0提问于2018-03-28得票数 1
回答已采纳
1回答
我有一个多绑定弹簧云流应用程序，实现与文档中解释的实现完全类似。
我打算重新尝试配置的次数，并最终放弃。
但
如果错误类似于下面的错误，它甚至不会进入监听器代码来应用x-death计数逻辑。因此，问题是如何放弃带有反序列化和消息转换错误的消息：
2018-09-06 16:41:11.889 ERROR [data-connector,671345aea4270626,48dd1100d9e332f9,false] 8866 --- [rdedStarGroup-1] o.s.integration.handler.LoggingHandler : org.springframework.
浏览 0提问于2018-09-06得票数 1
回答已采纳
1回答
，我有这个代码
@Bean
open fun messageConverter(om: ObjectMapper): MessageConverter {
return Jackson2JsonMessageConverter(om)
}
@Bean
open fun rabbitListenerContainerFactory(cf: ConnectionFactory, mc: MessageConverter ): SimpleRabbitListenerContainerFactory {
val factory = SimpleRabbitListenerConta
浏览 2提问于2019-03-06得票数 1
回答已采纳
我想知道与使用Spring AMQP手动接收消息相比，使用SimpleMessageListenerContainer的优点和缺点。另一个问题是，当我们创建SimpleMessageListenerContainer设置一个队列时，rabbitmq是否调用listeneradaptor，或者SimpleMessageListenerContainer是否一直轮询队列以检查消息，并在消息为message时调用已注册的适配器。
浏览 4提问于2014-06-12得票数 0
我想在java RabbitMq( SpringBoot )中实现一个AMQP消息，但是当我收到消息时，它说不能反序列化这个message，因为即使我在类路径中有该类，也找不到我应该接收的对象的类。
RabbitMqListener.java:
@EnableRabbit
@Component
public class RabbitMqListener {
Logger logger = Logger.getLogger(RabbitMqListener.class);
@RabbitListener(queues = "queue2")
public
浏览 10提问于2016-07-11得票数 1
回答已采纳
我们有一个用Kotlin实现的RabbitListener。该方法返回Unit，所以我不希望Spring发送结果，但我们得到了以下错误消息。看起来Spring尝试将Unit作为结果进行iterprete，并发回一条兔消息： 2021-04-16 16:39:21
msg="Execution of Rabbit message listener failed." thread="org.springframework.amqp.rabbit.RabbitListenerEndpointContainer#0-2" level=WARN logger="
浏览 46提问于2021-04-16得票数 0
我正在使用spring amqp rabbitmq，并使用
Message message = MessageBuilder
.withBody(item.toString().getBytes())
.setReplyTo("importReply")
.setCorrelationId(item.toString().getBytes()).build();
我的消息处理程序是
public class Foundation {
public Message importExchange(Message exchange) {
System.o
浏览 0提问于2014-04-23得票数 5
回答已采纳
我使用的是Spring，当RabbitMQ关闭时，我会得到异常，异常会被抛出。我希望能够捕获它，以便打印“重试连接”之类的任何内容。
org.springframework.amqp.AmqpConnectException: java.net.ConnectException: Connection refused (Connection refused)
at org.springframework.amqp.rabbit.support.RabbitExceptionTranslator.convertRabbitAccessException(RabbitExcepti
浏览 14提问于2020-02-11得票数 1
我们一直在使用一个框架来使用Spring AMQP，该框架设置了SimpleMessageListenerContainer.setDefaultRequeueRejected(false)，
这意味着如果从消费者抛出异常，默认消息将不会重新排队。
有没有方法可以在不更改SimpleMessageListenerContainer.setDefaultRequeueRejected(true)的情况下更改此行为
浏览 58提问于2017-01-23得票数 3
我是一个经验丰富的Java程序员，我第一次尝试Spring。
我遵循了消息传递--兔the教程，完全是使用Maven的。
我是作为用户帐户在CentOS上运行的。
当我在教程的最后使用java -jar target/gs-messaging-rabbitmq-0.1.0.jar运行应用程序时，我得到了下面的连接拒绝错误。有人能帮忙吗？
prompt> java -jar target/gs-messaging-rabbitmq-0.1.0.jar
. ____ _ __ _ _
/\\ / ___'_ __ _ _(_)_ _
浏览 7提问于2015-05-13得票数 3
回答已采纳
我目前正在Kotlin的一个项目中工作，该项目使用rabbit和reactor来接收某种DTO类型的消息，如果它们符合特定的标准，则将其发送。在测试代码的过程中，我尝试模拟错误的消息输入(因为消息来自外部服务)，并查看订阅者的行为。一旦我收到一条错误的输入消息，订阅者就会停止监听任何新的输入，并抛出以下异常：
org.springframework.messaging.MessageDeliveryException: Dispatcher has no subscribers for channel 'application.calculateAverage-in-0'.;
浏览 14提问于2021-02-21得票数 4
如果可能的话，该怎么做呢？
我目前正在从我的应用程序连接到AMQP ( rabbitmq )，如果rabbitmq关闭了，那么AmqpConnectionException就会抛出，它会重试10次以再次建立连接。
15:50:41.533 [SimpleAsyncTaskExecutor-173] WARN o.s.a.r.l.SimpleMessageListenerContainer - **Consumer raised exception,** processing can restart if the connection factory supports it.
**Excep
浏览 0提问于2015-10-30得票数 0
大家晚上好
我使用SpringXD-1.3.0.RELEASE (配置:3个管理和3个容器)和RabbitMQ 3.5.7 (3个节点)运行到以下场景：
stream create --name fire --definition "time --timeUnit=MILLISECONDS > topic:fire" --deploy
stream create --name fireeater_1 --definition "topic:fire > null"
stream create --name fireeater_2 --defi
浏览 5提问于2016-02-22得票数 1
回答已采纳
我在sl4j-api 1.7.2中使用Springboot。 有没有办法从堆栈中过滤掉-只跟踪以我的包开始的行，或者从日志文件中排除来自spring框架或我使用的其他库的行。 这将简化日志文件的读取，并极大地减少日志文件所需的空间。在超过99%的情况下，错误出现在我的代码中，而不是我使用的库中。 我想在开始我的onw，自制的解决方案之前，看看是否有任何统一的解决方案。 例如：此30+行很长的堆栈跟踪 2020-12-18 03:59:40,179 [SimpleAsyncTaskExecutor-2] ERROR RestCommunicatorImpl - sort
com.my.pack
浏览 44提问于2020-12-24得票数 3
我有以下RabbitMQ配置
@Configuration
@IntegrationComponentScan
public class RabbitConfig {
@Autowired // TODO constructor!
private ConnectionFactory connectionFactory;
public RabbitConfig(
@Value("${article.inbound.queue}") String queueName,
@Value("${article.inbound.exchange}
浏览 0提问于2018-09-20得票数 0
回答已采纳
我正在尝试在我的spring-core开发的应用程序中实现rabbitmq。下面是我的pom.xml
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-core</artifactId>
<version>5.2.6.RELEASE</version>
</dependency>
<depen
浏览 665提问于2020-05-29得票数 1
我有我的springboot应用程序，它连接到一个RabbitMQ队列，在该队列中，我以指定的Json格式推送消息，例如：{"messageId":"de5fe5a3-1831-4b87-891d-e7a4c29295b4","message":{"listingId":"2"},"errors":[]}，我确实创建了相应的Java命令but，但是我不知道如何将rabbbitMq消息直接解析成java对象。我找到了和杰克逊ObjectMapper一起做这件事的方法，但是我想让春天自己来做，而不是我自
浏览 0提问于2018-10-10得票数 2
回答已采纳
1回答
在我的项目中，我有一个听众：
@Service
@RequiredArgsConstructor
@Slf4j
public class ConsumerService {
@RabbitListener(queues = "${queue.treatment.request}")
public void handleQueueTreatmentRequestMessageReception(AppointmentPayloadDTO myAppointment) {
log.info(" ======================
浏览 6提问于2020-05-10得票数 0
1回答
嗨，我想在春季集成XML中实现死信交换，所以场景是AAA 绑定BBB队列如果BBB队列在某些场景中失败，比如lister抛出异常，我想导航异常到死交换队列以存储下面的消息。
创建样例项目
main.java
package com.spring.rabbit.first.deadletter;
import org.springframework.context.support.ClassPathXmlApplicationContext;
public class Main {
public static void main(String[] args) {
n
浏览 3提问于2017-02-15得票数 0
回答已采纳
1回答
虽然服务只有一个参数，但在使用spring和kotlin组合时，我总是碰到参数不匹配。我还调试了org.springframework.remoting.support.RemoteInvocation.invoke方法，我可以看到它正在传递准确的1参数和正确的targetObject。但invoke(targetObject, this.arguments);导致参数失配。
源代码：
异常
Caused by: **java.lang.Throwable: argument type mismatch**
at sun.reflect.NativeMethodAccessorImp
浏览 2提问于2018-04-13得票数 1
回答已采纳
我遇到了与相同的问题，与rabbitmq中断连接的时间相同，因为它已经启动。我在上有一个最小的项目。
这是一个Spring项目，其中两个码头容器正在运行。一个带有RMQ，另一个带有psql。在运行项目时使用容器是没有问题的，只是似乎不稳定的rabbitmq测试容器。我确实尝试将容器包装在一个通用容器中，结果是一样的。
查看容器是否已启动并运行的第一个测试通过了，因此它似乎仅与amqp连接有关。
Configclass：
@SpringBootTest(classes = TestContainersDemoApplication.class)
@Testcontainers
@AutoConf
浏览 37提问于2022-11-18得票数 1
回答已采纳
我使用RabbitMQ AMQP2.2.7。我让RabbitMQ集群在两个Spring应用程序之间运行。一个应用程序向另一个应用程序发布一些消息。它运行了一段时间，但在最近几天突然间，我看到应用程序中的MessageListener由于某种原因而下降(可能是主服务器节点崩溃了)。
<dependency>
<groupId>org.springframework.amqp</groupId>
<artifactId>spring-rabbit</artifactId>
浏览 10提问于2020-07-22得票数 4
回答已采纳
1回答
对于基于流的服务，当在@StreamListener中调用的底层服务失败时，我希望消息保持在队列中。为此，我的理解是，实现此目的的唯一方法是配置spring.cloud.stream.bindings.channel_name.consumer.acknowledge-mode=MANUAL。
在进行此配置更改之后，我尝试将@Header(AmqpHeaders.CHANNEL) Channel channel,@Header(AmqpHeaders.DELIVERY_TAG) Long deliveryTag作为方法参数添加到现有的@StreamListener实现中，如在上记录的那样。有了
浏览 5提问于2018-01-10得票数 2
回答已采纳
1回答
我想要创建一个模块，它将过滤来自输入通道的消息，并将它们转换为输出中的其他内容。我知道我可以将其分为两个模块(我更喜欢Java代码而不是脚本)，例如：
@Filter(inputChannel = "input", outputChannel = "output")
public boolean accept(final Message<?> message) {
final MyObject payload = (MyObject) message.getPayload();
return payload.getName().equ
浏览 1提问于2016-05-05得票数 3
回答已采纳
当我像这样调用微服务rest api时： Response<List<RoomPlay>> response = reportRoomHappyBombDetailController.happybombRoomDetailAnalysis(BizAnalysisConstant.DEFAULT_ANALYSIS_PREV_DAY, roomPlay.getId()); 抛出此错误： 2020-04-01 23:46:00.954 ERROR 1 --- [cTaskExecutor-1] c.s.s.r.c.room.RoomCreateMessageHandler
浏览 92提问于2020-04-01得票数 1
回答已采纳
我已经安装了dlq和dlx，但是失败的消息没有重定向到dlq。我试图从java应用程序以及从rabbitmq服务器向MESSAGES.EXCHANGE发送消息，在这两种情况下，我都收到消息，但是抛出异常消息后应该重定向到DLX.MESSAGES.EXCHANGE，但它正在发生。
下面是的java代码和屏幕截图。在我看来一切都是对的。无法在代码或rabbitmq服务器中找到任何问题。
队列设置代码-
public class DLQAmqpConfiguration {
public static final String DLX_MESSAGES_EXCHANGE = "DLX
浏览 2提问于2020-08-27得票数 2
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
