spring-amqp 相关问题

基于AMQP的消息传递的Spring组件。

将RabbitTemplate.convertSendAndReceive与org.springframework.messaging.Message一起使用

我已成功使用以下命令发送org.springframework.amqp.core.Message并接收byte [] import org.springframework.amqp.core.Message; import org.springframework.amqp.core ....

rabbitmq spring-amqp

回答 1 投票 2

消息已发布但从未到达经纪人

我的兔子模板配置为使用CachingConnectionFactory和缓存模式连接。在极少数情况下，当调用rabbitTemplate.convertAndSend时，它传递的没有任何问题，但消息...

spring-amqp

回答 1 投票 0

Spring AMQP + RabbitMQ 3.3.5 ACCESS_REFUSED - 使用认证机制PLAIN拒绝登录

我收到以下异常org.springframework.amqp.AmqpAuthenticationException：com.rabbitmq.client.AuthenticationFailureException：ACCESS_REFUSED - 使用身份验证拒绝登录...

rabbitmq spring-integration spring-amqp

回答 8 投票 66

获取java.lang.noclassdeffounderror：org.springframework / amqp / core / corelation

我的spring_boot_version是'2.0.5.RELEASE'，spring_version ='4.3.8.RELEASE'和我正在为rabbit mq运行的弹簧依赖项是：compile（“org.springframework.boot：spring-boot-starter-。 ..

linux spring-boot spring-amqp spring-messaging

回答 1 投票 1

RabbitTemplate和ReplyTimeOut

我有一个项目，我设置超时5秒（getRabbitTemplate（）。SetReplyTimeout（5000）），我使用sendAndReceive方法发送消息：getXbidRabbitTemplate（）SendAndReceive（...

spring-amqp

回答 1 投票 0

绑定交换以通过Spring cloud stream与rabbitmq binder交换

我正在寻找一种通过Spring云流将RabbitMQ交换绑定到另一个的方法。我知道我可以通过设置producer.requiredGroups属性将队列绑定到交换：spring.cloud ....

rabbitmq spring-amqp spring-cloud-stream spring-rabbitmq spring-rabbit

回答 1 投票 0

使用参数构建自定义弹簧注释？

是否可以将此注释转换为@RabbitListener（bindings = [QueueBinding（key = [Amqp.FOLEY_NEW]，value = Queue（Amqp.FOLEY_NEW），exchange = Exchange（name =“amq ....

spring kotlin spring-amqp

回答 1 投票 0

Spring Integration是否支持Azure Service Bus？

我需要使用Azure Service Bus进行消息传递，并希望尝试Spring Integration AMQP支持。我找不到任何相关的例子或任何建议这是可能的。

spring-integration amqp azureservicebus spring-amqp spring-integration-amqp

回答 1 投票 0

如何在Spring Boot和RabbitMQ中配置和receiveAndConvert jSON有效负载到域对象

最近，我对使用Spring Boot的微服务架构产生了浓厚的兴趣。我的实现有两个Spring启动应用程序; Application One接收来自RESTful API的请求，......

java spring rabbitmq spring-boot spring-amqp

回答 3 投票 5

spring amqp默认启用重试，并根据指定的异常阻止它

在例外情况下A：重试有限次数，最后当重试次数耗尽时，消息写入死信队列。如果是异常B：简单地说，消息应该......

rabbitmq spring-amqp spring-rabbitmq retrypolicy

回答 2 投票 0

是否可以使用RabbitListener声明这些绑定？

给出这段代码@Bean open fun exchange（）：TopicExchange {return TopicExchange（“amq.topic”）} @RabbitListener（queues = [Amqp.BODY_WEIGHT_NEW]）打开有趣记录（实体：...

spring-boot kotlin spring-amqp

回答 1 投票 0

如何为@RabbitListener注释编写集成测试？

我的问题实际上是对RabbitMQ集成测试和线程的后续问题它说它包装“你的监听器”并传入CountDownLatch并最终所有线程将合并....

spring-amqp spring-rabbit

回答 2 投票 5

有没有办法使用rabbit-template找到队列是空的

我有订阅者收集消息，直到达到指定的限制，然后将收集的消息传递给处理器以执行某些操作。代码工作正常，问题是订阅者......

spring-boot spring-amqp

回答 1 投票 0

来自一个Queue RabbitMQ Spring的多个监听器

我正在研究一个示例例子，从这个队列中有一个队列和2个侦听器，小问题和问题......当有很多消息时，sutric线程正在自杀，当有低...

java spring rabbitmq amqp spring-amqp

回答 1 投票 0

Spring amqp使用者在网络故障后没有重新连接到队列

我们有一个spring应用程序，它有一个动态队列监听器连接到rabbitmq中的队列。假设我的弹簧应用程序总共有5个侦听器消费者连接到5个队列...

java spring rabbitmq spring-amqp

回答 1 投票 0

如何从收听者发送回复

我正在从事Java和RabbitMQ学习的家庭作业。我对Spring和RabbitMQ并不熟悉，但我无法解决这个问题。我有2个单一的申请。第一个，......

spring rabbitmq spring-amqp spring-rabbitmq

回答 1 投票 0

如何使用spring rabbitmq配置不同队列中的超时，重试或最大尝试次数

是否可以为每个队列进行这些设置？我有重要的队列，所以我需要更多的重试，但有不太重要的队列，我不想配置重试，...

java rabbitmq spring-amqp spring-rabbitmq

回答 3 投票 2

带有rabbitmq集群和spring amqp的负载均衡器

我想在负载均衡器后面设置一个rabbitmq集群，并使用spring amqp连接到它。问题：Spring客户端是否需要知道RMQ集群中每个节点的地址，或者它是......

rabbitmq spring-amqp spring-rabbitmq

回答 1 投票 0

如何解析Spring AMQP中的JSON对象？

有一个远程RabbitMQ服务器，它只允许我发送和接收消息。这意味着我无法创造任何东西。我发送了一个请求，并以JSON格式得到答案。在我的申请中我......

java spring rabbitmq amqp spring-amqp

回答 2 投票 3

RabbitMQ DirectMessageListenerContainer中的消费者 - Cloud Foundry中的内存影响

我有一个场景，我在DirectMessageListenerContainer bean中为队列创建预定义的使用者，如下所示：@Bean public DirectMessageListenerContainer ...

spring-boot rabbitmq cloudfoundry spring-amqp

回答 1 投票 0

spring-amqp 相关问题

最新问题