基于AMQP的消息传递的Spring组件。
我正在使用RabbitMQ / Spring / Spring AMQP构建应用程序,并且在处理排队方式时遇到了麻烦。本质上,我有一个队列,每个消费者都在听,每个队列都在听...
我正在使用spring-boot创建批量视频处理系统。在这里,用户将通过xlsx表格提供所有与视频相关的信息,我们将在后端处理视频。我正在使用...
我可以能够与RabbitMQ的通过http层与下面的连接性能和需要帮助与HTTPS URL,spring.rabbitmq.host =本地主机spring.rabbitmq.port = 5672 spring.rabbitmq连接....
我试图实现对每个租户的应用程序将数据发送到通过RabbitMQ的春天启动应用程序的多租户春季启动应用程序的支持。每个租户连接到自己的...
少出现,从生产,其中示出的RabbitMQ控制台不存在用于队列中没有报道听者。从应用以及从RabbitMQ的服务器日志没有相关的错误...
集成测试的RabbitMQ听者 - 间歇性地失败,因为消息需要时间来排队
我已经写了一个集成测试使用RabbitMock以下流(发现它在GitHub上,它似乎真的很酷):消息被添加到传入的消息队列 - >进入消息听者...
我想在这里了解一些事情。我的要求是我想在db中存储记录并希望将消息发送到队列然后让我们说同样的方法如果它抛出一些我不想要的异常...
我读了很多文档/ stackoverflow,但是当发生异常以将消息移动到死信队列时,我仍有问题。我正在使用spring-boot这是我的配置:@Autowired private ...
RabbitMQ通过Spring的RabbitAdmin调整HA队列
我想知道:有没有办法只使用Java Spring代码设置RabbitMQ镜像(HA队列)。 AFAIK有一个特殊的类RabbitAdmin用于这样的配置问题,但不能......
这是我当前的设置:将queue1和queue2与集成流合并到通道1:@Bean public IntegrationFlow q1f(){return IntegrationFlows .from(...
独占消费者失败时要处理的AmqpEvent或AmqpException
我有两个相同应用程序的实例,在不同的虚拟机中运行。我想为其中一个的使用者授予对队列的独占访问权限,同时使本地缓存无效...
在TomCat上没有配置的Task Executor的DirectMessageListenerContainer?
我正在为我的消息传递应用程序设置DirectMessageListenerContainer。我正在与Tomcat,Spring,AMQP合作。文档有这个警告https://docs.spring.io/spring-amqp/reference/#threading ...
我正在尝试使用Spring AMQP,版本2.1.2.release来创建多个绑定到主题交换。我发现了这个问题:如何使用...在RabbitMQ Java配置类中设置多个主题
Spring MongoDB无法实例化Map类型:org.springframework.messaging.MessageHeaders
我正在使用带有RabbitMQ和MongoDB的Spring启动。我有一个死信队列设置,它将我的DeadLetterMessage保存在Mongo中。当我想从数据库中检索这些消息以重新排队时......
使用spring boot 1.5.9 RELEASE,代码如下@Configuration @EnableRabbit public class RabbitmqConfig {@Autowired ConnectionFactory connectionFactory; @ Bean //有或没有这个bean,...
如何在春季启动测试中模拟spring amqp / rabbit
如何模拟spring rabbitmq / amqp,以便在尝试自动创建交换/队列时在Spring Boot Test期间不会失败?鉴于我有一个简单的RabbitListener将导致队列和......
我正在为我的应用程序编写集成测试,以便向RabbitMq发送消息。作为我的测试配置的一部分,我正在声明一些RabbitListeners来获取这些消息。我知道我不太远,...
Spring-boot 2 rabbitmq MessageConverter不能正常工作
我正在使用弹簧靴和rabbitmq。我在这里有类似的情况。我想将我的消息映射到自定义java对象我也想要传递传递标签,这是我希望的消息属性...
使用application.yml springboot和config server在RabbitMQ服务器上创建virtualHost
Virtualhost没有基于配置在RabbitMQ服务器上创建我是否确保在RabbitMQ上使用VH aka虚拟主机。我错过了一些配置。请找配置...
Spring Boot 2 + Websockets +负载均衡器
我们使用spring boot + websocket从服务器向客户端(基于用户登录)编写了简单的消息发送机制。目前它在一台服务器上运行,运行正常。但我们......