spring-rabbit

0熱度

1回答

RabbitMQ/Spring：如果目前的獨家消費者註冊，另一位獨家消費者會註冊嗎？

我有一個在cloudfoundry上運行多個實例的spring應用程序。這些實例共享一個數據庫。他們有配置像這樣一個RabbitListener：如果需要的物品從某個源重新導入 @RabbitListener(queues = "${items.updated.queue}", exclusive = true) 隊列獲得消息。我只希望一個實例執行導入。根據我的理解，這可以通過專有標誌來實

0熱度

1回答

SpringBoot禁用rabbitTemplate重試兔健康檢查政策

我SpringBoot配置包含很強的重試政策rabbitTemplate試 spring: rabbitmq: template: retry: enabled: true initial-interval: 500 max-attempts: 10 multiplier: 5 max-interval:

1熱度

1回答

如何避免在發生意外錯誤時關閉SimpleMessageListenerContainer？

我正在使用Java boot 1.4.0和'spring-boot-starter-amqp'來連接到rabbitMq。消息製作者，消費者和rabbitMq服務器都在我的控制之下。在製作過程中，幾個月的事情都很好。但突然我的消費者停止了下面給出的例外。由於我只生產總是有效的信息，我不知道哪裏出了問題。但是這導致我的聽者容器關閉。因此我的消息處理已停止。我不得不手動重新啓動消息使用者程序。所以我

4熱度

2回答

如何在spring引導應用程序中處理與spring-rabbit的JSON消息？

這是我的代碼片段。 MQConfiguration類配置爲處理接收消息 @RabbitListener(queues = "testMQ") public class Receiver { @RabbitHandler public void receive(Message msg){ System.out.println(msg.toString());

3熱度

1回答

如何一起使用Rabbit連接緩存模式和Autodeclare功能？

的Spring AMQP Reference說：與1.3版本開始，CachingConnectionFactory可配置爲高速緩存的連接以及剛剛渠道。在這種情況下，每次調用createConnection()都會創建一個新連接（或從緩存中檢索一個空閒連接）。關閉連接會將其返回到緩存（如果尚未達到緩存大小）。在這種連接上創建的通道也被緩存。在某些環境中使用單獨的連接可能很有用，例如從HA羣集消耗，

0熱度

1回答

春天啓動的RabbitMQ DLE不接受我的春天啓動的RabbitMQ工作的任何消息

。我創建一個死信隊列，我可以能夠RabbitMQ的管理爲「d，DLE」，但沒有DLK看可能是我失蹤設置「X-死信路由鍵」，事情是我不希望我的路由消費者key.Few綁定到特定的交流，我創建每個交換DLE如果有那麼DLE連接到接收消息，並做了用戶依賴logic.But是交換爲交換消費者的任何問題不幸的是，這不起作用，DLE沒有收到任何消息。請找到下面的代碼， package com.sample.

0熱度

1回答

Spring-rabbit中的ClassNotFoundException取決於消費者或生產者何時啓動

我使用spring-spring和spring-amqp和RabbitMQ在本地運行的兩個JVM之間發送消息。根據我開始每個應用的順序，我有時會得到一個ClassNotFoundException。我有一個像這樣的多項目設置： - Project root - common (contains all events/messages that are sent) - serve

0熱度

1回答

我們能有一個超時在消費端在Spring AMQP

設置，我們可以有一個超時在春季AMQP消費端的設置，我們這裏AMQP的消息在消費者端得到一個用例 @Named("TestListener") public class TestListener implements MessageListener { @Override public void onMessage(Message message) { //

0熱度

1回答

Spring RabbitTemplate setRetryTemplate＆setRecoveryCallback ignored

問題：經過一段固定的重試次數後，我想將消息發送到一個錯誤隊列並從其原始隊列中消耗它。我想找到一個通用的解決方案，因爲我處理了很多不同的消息，並且根據他們引發的異常，我想採取不同的行動。我如何設置RecoveryCallback以便Spring在maxRetries之後觸發它？我現在做什麼我嘗試設置RetryTemplate和RecoveryCallback。當我運行應用程序並將消息發佈到te

0熱度

1回答

Spring集成的RabbitMQ +消費從amq.rabbitmq.event話題交換

內部事件我想消費被髮布到amq.rabbitmq.event如client.connected內部事件，client.disconnected。下面是我的Spring配置文件： <?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns