RabbitMQ @RabbitListener注解在Spring中不起作用(不是spring-boot)

文章/答案/技术大牛

发布

1回答

java、spring、rabbitmq、spring-rabbit

我正在尝试在我的spring-core开发的应用程序中实现rabbitmq。pom.xml <groupId>org.springframework</groupId> </dependency>

浏览 665提问于2020-05-29得票数 1

1回答

如果我手动配置DirectMessageListenerContainer，则忽略spring.rabbitmq.listener.simple.retry.enabled=true

rabbitmq、spring-amqp、spring-annotations、spring-rabbit

我正在尝试使用属性激活rabbitmq上的死信队列spring.rabbitmq.listener.simple.retry.max-attempts=10public class SimpleConsumer { @RabbitListener(queues = "messages.queue")

浏览 16提问于2021-05-07得票数 0

1回答

在Spring中使用所有@RabbitListener-s的RabbitMQ消息

java、spring、spring-boot、rabbitmq、messaging

我正在配置一个示例，以检查RabbitMQ是否能够解决我的问题，并且正在运行一个问题。public void receiveMessage1(String message) { System.out

浏览 0提问于2018-12-11得票数 1

回答已采纳

1回答

在带有amqp的spring-boot中使用基于注释的侦听器来NACK消息的正确异常类型是什么？

spring-boot、spring-amqp、spring-rabbit

我使用spring boot和spring-amqp以及基于注解的监听器来使用rabbitmq代理的消息。我有一个spring组件，它包含如下方法： public void receiveMessage(@Payload Task在成功执行receiveMessage(...)之后，我使用AUTO模式来确认消息。如果我检测到一个特殊的错误，我会抛出AmqpRejectAndD

浏览 25提问于2016-08-30得票数 1

回答已采纳

3回答

如何在Spring中侦听现有队列？

java、spring、rabbitmq、amqp、spring-amqp

我有一个远程RabbitMQ服务器，它有一些我想要侦听的队列。我试过这个：public void receive(String message) {@RabbitListener(queues = "#{autoDeleteQueue2.name}") 在一本教程里。#{queueName.name}是什么意思？org.springframewo

浏览 1提问于2018-08-30得票数 2

回答已采纳

1回答

Spring data rabbitmq @RabbitListener突然停止使用排队的消息。

spring-rabbit

我使用的是spring 2.1.1发行版和spring starter，@@RabbitListener虽然工作正常，但停止了使用消息。当我重新启动使用者API时，它开始正常工作。此外，在管理用户界面中，它没有显示此队列中的任何使用者。Java1.8版本在java客户端或rabbitmq服务器端没有例外。我试图通过rabbitmqctl重新同步队列，但是它仍然<e

浏览 0提问于2019-09-13得票数 1

0回答

spring-amqp消费器的性能非常慢

spring-amqp

我一直在使用spring-boot consumer遇到麻烦。我比较了两个消费者的工作。第一消费者：import java.io.IOException; private finalchannel.basicConsume(QUEUE_NAME, true, consumer);}@Controller @RabbitListener<

浏览 2提问于2016-12-25得票数 0

1回答

RabbitListener不是注释类型。

java、spring、maven、spring-boot、rabbitmq

我有一个基本的项目，我正在使用Spring工具套件。我正在尝试用RabbitMQ实现一个基本的消息传递，但是我无法导入RabbitListener注释。我在IDE RabbitListener is not an annotation type中得到错误消息。<?xml version="1.0" encoding="UTF-8"?SNAPSHOT</version> <packaging

浏览 0提问于2016-12-28得票数 0

回答已采纳

1回答

如何监听不同的虚拟主机队列？

spring-amqp

我需要同时连接多个虚拟主机，因为我想监听多个主机中的队列。默认情况下，基于配置的模式仅创建一个连接。如何创建多个连接？在注册带有注释的侦听器时，如何指定不同的连接工厂？spring.rabbitmq.host=10.0.0.0spring.rabbitmq.username=testspring

浏览 30提问于2019-02-22得票数 0

2回答

Keycloak安全Spring* Boot应用程序*

java、spring-boot、keycloak

我正在使用keycloak测试一个web应用spring boot的安全性，我添加了所有必要的依赖项，但我在撕裂应用程序时遇到了一个问题。我使用: spring boot 2.2.0.M3 Java 11 我包括: keycloak-spring-boot-starter和keycloak-adapter-bom 这是我的pom.xml：</id>

浏览 102提问于2019-05-23得票数 1

回答已采纳

1回答

如何在@RabbitListener中创建有状态服务

java、spring、spring-amqp、spring-rabbit

如何在消息(@RabbitListener)中创建有状态服务(多个@Autowire)，如果是新消息，状态应该是干净的。在@Service的RabbitQM(Spring AMQP)之前，我使用@Scope(value = WebApplicationContext.SCOPE_REQUEST, proxyMode =

浏览 8提问于2018-01-26得票数 0

1回答

如何在多个类中使用@RabbitListener？

java、spring、rabbitmq、message-queue、spring-amqp

我有一个使用RabbitMQ ( Spring Starter)的spring应用程序。 return BindingBuilder.bind(incomingQueue()).to(incomingQueueExchange()).with(queue);当我使用RabbitMQ管理工具向FanoutExchange发送消息时，DeadLetterQueue类中的processFailedMessa

浏览 1提问于2020-01-13得票数 2

1回答

使用JHipster-Registry集中微服务时出现Bean定义覆盖异常(云配置服务器作为中心服务器)

spring-boot、jhipster、jhipster-registry、jhipster-gateway

在JHipster-registry中集中微服务客户端的配置时，我目前遇到了一个问题。我正在使用文件系统的方法集中配置注册表应用程序的配置(central-config)文件夹。:: Running Spring Boot 2.1.6.RELEASE :: 2020-09-14 12:09:12.061 INFO=true 我已经尝试了一些方法，比如使用注册表应用程序的中央配置文件夹中的属性，.yml文件(保存客户端应用程序的中央配置) spri

浏览 20提问于2020-09-14得票数 0

1回答

如何将多个注释合并到一个注释中并重命名它们的属性

java、annotations

其目的是将几个spring验证注释组合在一起，并重新标记它们的默认属性。

浏览 0提问于2020-03-27得票数 2

1回答

捆绑包激活后未激活OSGI组件

spring-boot、osgi

我在OSGI中使用了spring-boot。在bundle activator中，spring-boot应用程序成功启动。我有一个组件类，如下所示 @Service // spring-boot annotationpublic在删除spring-boot注解@Service之后，代码可以正常工作。

浏览 13提问于2019-04-10得票数 0

1回答

Spring @AliasFor，带有嵌套批注的属性

java、spring、spring-amqp

可以让@AliasFor注解将参数传递给嵌套注解吗？将name()的值传递给@RabbitListener中的嵌套@Queue注释？

浏览 53提问于2021-11-17得票数 0

回答已采纳

1回答

为什么我的spring-cloud-stream测试配置还启动了另一个类中的rabbitMQ侦听器？

spring、unit-testing、spring-boot、spring-cloud-stream、spring-config

我正在尝试做一个简单的spring-cloud-stream单元测试来验证流之间的连接；基本上，处理程序可以从一个流中读取并写入到另一个流中。这部分运行得很好。问题是，应用程序的其他部分也在启动；即rabbitMQ侦听器。在另一个类中有一个方法(除了我正在测试的那个)，它有一个@RabbitListener。这就是被调用的方法。) 我认为是@SpringBootTest启动了整个配置，包括RabbitMQ侦听器。目前，解决方法是将spring<

浏览 46提问于2019-01-11得票数 0

回答已采纳

1回答

具有分布式查询模型的Axon寄存器跟踪处理器

spring-boot、event-handling、cqrs、event-sourcing、axon

我使用axon和spring-boot实现了CQRS+ES应用程序。我使用单独的查询模型和命令模型应用程序。我使用rabbitmq从命令模式发布事件。它工作正常。但是跟踪处理器实现在我的应用程序中是不起作用的。return new SpringAMQPMessageSource(new DefaultAMQPMessageConverter(serializer)) { @RabbitListener

浏览 0提问于2018-04-01得票数 0

1回答

队列Bean上的Spring集prefetchCount

java、spring、spring-amqp、spring-rabbit

topicExchange)} return factory;更新根据@GaryRussell下面的评论，我测试了默认的rabbitListenerContainerFactory，并验证了我的Spring配置spring.rabbitmq.listener.simple.prefetch正在Abs

浏览 2提问于2020-05-27得票数 2

回答已采纳

1回答

@RabbitListener()和DirectMessageListenerContainer在使用rabbitMQ时的区别

spring-boot、rabbitmq、spring-amqp

我正在尝试在spring中配置并发使用者以使用来自RabbitMQ的消息，以便通过两种方式配置使用者。1.用@RabbitListener(=“队列名称”)注释了一个方法在我的例子中，这两种方法都运行得很好，但我无法弄清楚使用@RabbitListener()启动消费者的优点/缺点是什么。此外，我还在配置中配置了"Dir

浏览 5提问于2021-05-13得票数 1

点击加载更多