spring-rabbit

0熱度

1回答

我們使用RabbitMQ作爲消息代理。 Producer1使用AMQP連接，Producer2使用STOMP協議連接，Consumer1使用AMQP連接，Consumer2（使用JavaScript）通過websocket使用STOMP連接。測試1：當使用AMQP的生產者1發送消息時，它在消費者1（AMQP）中接收，並且無法在消費者2（STOMP）中接收到消息。當producer1（AMQP）發送

0熱度

1回答

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

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

0熱度

1回答

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

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

0熱度

1回答

交易處理Rabbit MQ和Spring AMQP

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

1熱度

1回答

我可以創建Spring RabbitListener別名嗎？

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

0熱度

1回答

Spring RabbitTemplate.execute隊列關閉時掛起

我試圖執行獲取服務器屬性來聲明RabbitMQ通道的健康狀況。這裏是我的代碼： rabbitTemplate.execute(new ChannelCallback<String>() { @Override public String doInRabbit(Channel channel) throws Exception { Map<Strin

1熱度

1回答

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

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

0熱度

1回答

聽兔子隊列

我正在通過彈簧隊列聽兔子隊列和我收到此錯誤： org.springframework.amqp.rabbit.listener.exception.ListenerExecutionFailedException: Failed to invoke target method 'orchestrate' with argument type = [class [B], value = [{[[em

0熱度

1回答

RabbitMQ同一隊列的多個使用者

是否可以使用主題將消息發送到隊列，並讓2個使用者接收並處理相同的消息？目前，我創建了2個使用交換主題觀察隊列綁定的使用者，但第一個使用者使用該消息並刪除該隊列，而第二個使用者未收到該消息。

0熱度

1回答

Java RabbitMQ consumer.nextMessage總是得到相同的消息

我們在分佈式服務體系結構中使用Java rabbitMq進行spring引導。一個服務獲取HTTP請求並將其轉發到未知隊列進行處理。同時，它必須等待另一個隊列上的響應，才能終止HTTP請求。（這是預覽請求，由渲染器完成其工作）。可以有多個ServiceA（HTTP接口）和ServiceB（渲染器）的實例，所以每個預覽消息都會發送一個唯一的ID用作路由密鑰。我對BlockingConsumer