spring-rabbitmq 相关问题

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

是否有任何设置，以返回到第一个集群CachingConnectionFactory setAddresses

我正在使用CachingConnectionFactory的setAddresses方法为多个集群。 connection = new CachingConnectionFactory(); connection.setAddresses("rabbit1:5672,rabbit2:5672"); 当我关闭...

spring spring-boot rabbitmq spring-rabbitmq

回答 1 投票 0

kotlin对象（本地最终类）不可序列化。

由于某些原因，我需要在kotlin中像下面这样构造一个对象，并需要使用rabbitTemplate.convertAndSend发送至rabbitMQ。但是当我这样做的时候，我得到一个错误 var myObject = object ...。

kotlin spring-rabbitmq

回答 1 投票 0

CachingConnectionFactory确认类型简单与相关。

CachingConnectionFactory确认类型简单与相关的区别是什么。

spring-boot rabbitmq spring-amqp spring-rabbitmq

回答 1 投票 0

Spring boot rabbitmq没有交换'"xxxxxx"'在vhost''

我正在用spring boot 2.2.7编写一个简单的rabbitmq producer。在代理方面，我已经设置了一个直接交换样本，一个名为samples.default的队列，并将它们绑定在一起，添加了一个samples......。

spring-boot spring-rabbitmq rabbitmq-exchange

回答 1 投票 0

RabbitTemplate: 经纪人不支持通过'amq.rabbitmq.reply-to'快速回复。

为什么RabbitTemplate不能使用direct-reply？是否有任何与broker有关的配置？

rabbitmq spring-rabbitmq

回答 1 投票 0

Spring AMQP RabbitListener调整自动重连配置。

我试图更好地理解RabbitListener的行为，当broker宕机时& 当它被恢复时。我已在本地主机：6672 的 docker 容器中设置了一个 rabbit，并创建了一个 ...

rabbitmq spring-amqp spring-rabbitmq

回答 1 投票 0

setConfirmCallback vs setReturnCallback

为什么setReturnCallback执行在setConfirmCallback之前，理想情况下setConfirmCallback回调方法应该执行在返回回调之前。

rabbitmq spring-amqp spring-rabbitmq

回答 1 投票 0

当消息不能被RabbitMQ路由时，Publisher确认会给出ACK。

我正在做一个小项目来检查RabbitMQ的Publisher Confirms与Spring Cloud Stream 3.0.1的工作情况。我有一个特殊的情况，当一个消息被发送到RabbitMQ的交换，但这......

rabbitmq spring-integration spring-cloud-stream spring-rabbitmq

回答 1 投票 0

将docker容器中的java应用连接到rabbitmq。

我有一个java应用程序在docker容器中运行，rabbitmq在另一个容器中。我如何连接这些容器在我的应用程序中使用rabbit？

docker spring-rabbitmq

回答 1 投票 0

Spring AMQP多线程调用消息监听器

我有一个DirectRabbitListenerContainer(通过DirectRabbitListenerContainerFactory创建)，其中我通过MessageListenerAdapter设置了一个MessageListener。我所遇到的问题是...

spring rabbitmq spring-amqp spring-rabbitmq

回答 1 投票 0

客户端如何通过RabbitMQ与服务通信？

我目前正在学习使用RabbitMQ在它们之间进行通信的微服务架构。我想到了管理不同微服务之间的通信的想法，但我并没有真正发现...

spring rabbitmq microservices spring-rabbitmq

回答 1 投票 0

spring-boot-starter-amqp无法使用仅具有写许可权的用户凭据将消息发送到AMQP交换

我正在尝试从springboot应用程序向RabbitMQ发送消息。使用的依赖项（springboot和amqp）： org.springframework.boot＆...

spring-boot spring-amqp spring-rabbitmq spring-rabbit cloudamqp

回答 1 投票 0

在RabbitListenerErrorHandler中发送回复，但仍发送NACK消息？

我有一条使用Spring Boot和RabbitMQ处理任务的服务管道。每个服务都使用队列中的消息，进行一些工作，然后重新发送，作为要由...处理的消息，以进行处理...

spring rabbitmq spring-amqp spring-rabbitmq

回答 1 投票 0

发布者确认使用Spring Cloud Stream

我有兴趣使用Spring Cloud Stream在我们项目中的某些生产者中使用发布者确认。我曾尝试做一个小的PoC，但是它不起作用。据我所见...

rabbitmq spring-cloud-stream spring-rabbitmq

回答 1 投票 0

RabbitMQ Atleast一次发送配置时间间隔

我已阅读到，如果某个使用者接受了一条消息，但未确认在给定的时间范围内已成功处理该消息，那么将向另一个使用者提供相同的消息以保证...

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

回答 1 投票 0

在RabbitMQ中删除或更新消息

我已经进行了一些研究，但无法找到任何解决方案来删除或修改队列中已经存在的消息。（RabbitMQ）。用例：我正在尝试使用延迟的方式发送通知...

java rabbitmq spring-rabbitmq

回答 1 投票 0

Spring cloud stream + spring retry，如何添加恢复回调并禁用发送到DLQ的逻辑？

spring-cloud spring-cloud-stream spring-rabbitmq spring-retry

回答 1 投票 0

RabbitMQ @RabbitListener注释在Spring中不起作用（不是spring-boot）

我正在尝试在我的spring-core开发的应用程序中实现Rabbitmq。以下是我的pom.xml org.springframework

java spring rabbitmq spring-rabbitmq

回答 1 投票 1

从Rabbitmq接收器获取消息->将byte []转换为ArrayList

我发现了这个问题：将byte []转换为ArrayList 并尝试了以下解决方案：@RabbitListener（queues =“ queue-tracking”）public void receive（Message message）{byte [] ...

arrays string arraylist rabbitmq spring-rabbitmq

回答 1 投票 0

Spring AMQP在队列Bean上设置prefetchCount

我如何为此队列使用者设置prefetchCount？ @Bean public Queue eventQueue（AmqpAdmin amqpAdmin）{队列队列= QueueBuilder.durable（EVENT_QUEUE_NAME）... ....

java spring spring-amqp spring-rabbitmq spring-rabbit

回答 1 投票 0

spring-rabbitmq 相关问题

最新问题