spring-amqp

0熱度

1回答

如何防止ListenerExecutionFailedException：監聽器拋出異常

我需要做些什麼來防止RabbitMQ推測的以下異常。 org.springframework.amqp.rabbit.listener.exception.ListenerExecutionFailedException: Listener threw exception at org.springframework.amqp.rabbit.listener.AbstractMessag

spring-integration spring-batch spring-amqp 2017-10-06

---

0熱度

2回答

spring-boot-starter-amqp將在微服務之間起作用嗎？

我是Spring amqp的新手。 我試圖通過以下方式發送消息：https://spring.io/guides/gs/messaging-rabbitmq/ 我能夠在微服務內發送消息。 但無法發送消息到另一個微服務？是否預計？ 如果我想發送微服務之間的消息，我應該遵循的依賴關係？ 請幫我這裏。

spring-boot spring-amqp spring-rabbitmq 2017-10-06

---

0熱度

1回答

Spring AMQP和Spring Rabbit的哪個版本與Spring 5兼容？

我得到的錯誤了春兔和Spring AMQP的升級後彈簧5 兩個現在設置爲1.5.6.RELEASE 有誰知道哪個版本應該是與Spring兼容5？ 更一般地說，任何人都知道，如果某處有一個保存在任何地方的兼容版本的Spring項目的主列表？

spring spring-amqp spring-rabbit 2017-10-07

---

0熱度

1回答

爲什麼Jackson2JsonMessageConverter的AmqpChannelFactoryBean不存儲類型？

我試圖使用Spring與RabbitMQ集成，使用RabbitMQ支持的Spring集成通道。 （由於某種原因，似乎幾乎沒有記錄，這是新的？）。 要做到這一點，似乎我可以使用AmqpChannelFactoryBean來創建一個頻道。 爲了建立消息轉換，我使用了Jackson2JsonMessageConverter。 當我使用帶有POJO負載的GenericMessage時，它拒絕從Java反序

spring-integration spring-amqp spring-integration-amqp 2017-10-10

---

0熱度

1回答

消息不發送，如果我不指定隊列，TopicExchange，在SpringBootApplication

綁定我試圖發送消息如下： rabbitTemplate.convertAndSend("my.exchange", "my.queue", "Test Message"); 並試圖如下接收消息： @RabbitListener(bindings = @QueueBinding(value = @Queue(value = "my.queue", durable = "true"), excha

spring-boot spring-amqp spring-rabbit spring-rabbitmq 2017-10-10

---

0熱度

1回答

交易處理Rabbit MQ和Spring AMQP

我想在這裏理解一些東西。我的要求是我想將記錄存儲在數據庫中，並希望將消息發送到隊列，然後讓它在相同的方法中說，如果它引發一些異常我不想發送消息，也不想提交數據庫事務。 現在我想到使用春季交易，但由於兩個不同的資源，想到使用JTA使用一些atomikos來同步資源 - 但我再次讀到RMQ不支持2PC或XA等 無論如何，我繼續前進，沒有添加atomikos，我所做的一切都是確保我的頻道和@Transa

spring-amqp spring-rabbit 2017-10-13

---

0熱度

1回答

Spring AMQP Auto Scaling Group

因此，我一直在使用主題交換來研究Spring AMQP和Spring Cloud Stream。如果我在AWS自動擴展組中擁有該應用程序，該應用程序的額外實例是否會訂閱相同的交換並接收到重複的消息？

amazon-web-services spring-amqp spring-cloud-stream 2017-10-13

---

1熱度

1回答

我可以創建Spring RabbitListener別名嗎？

我有@RabbitListener(id="example", queues={"a", "b"})偵聽器，我複製粘貼在我的代碼中的多個位置通過不同的模塊。我想創造一個別名，如： @Target({ ElementType.TYPE, ElementType.METHOD, ElementType.ANNOTATION_TYPE }) @Retention(RetentionPolicy.RUN

java spring spring-amqp spring-rabbit 2017-10-13

---

1熱度

1回答

Spring雲流自動重新連接到兔子MQ

我有一個連接到RabbitMQ服務器的Spring Cloud Stream應用程序。我們在Rabbit MQ中使用rabbitmq-auth-backend-uaa插件，但這不是問題。 該插件會檢查在創建與Rabbit MQ的連接時作爲用戶名發送的oAuth2.0 JWT令牌。 要做到這一點，我有這樣的代碼在我的Spring應用程序： @Bean @Primary ConnectionFac

spring rabbitmq spring-amqp spring-cloud-stream spring-rabbit 2017-10-17

---

0熱度

1回答

如何註冊一個隊列，並且它是RabbitMQ和Spring的獨佔使用者/偵聽器？

我有以下問題需要解決： 我想實現一個簡單的使用RabbitMQ消息傳遞的延遲重試機制。我有一個基礎設施，可以讓我延遲傳遞信息。我可以有任何想要在運行時利用這種延遲重試機制的感興趣的參與者。 參與者只想給我提供2個細節和消息： 1.隊列名稱，他們希望在延遲T秒後傳遞消息。 2.隊列的消費者（比如消息的消費者。） 我試圖做到以下幾點： private void startSeparateListene

rabbitmq spring-amqp spring-rabbitmq 2017-12-18

---