spring-rabbitmq

0熱度

1回答

Spring amqp：如何在MessageListenerAdapter中讀取MessageProperties

如果我在其簽名中添加MessageProperties，則handleMessage方法不會從隊列中獲取消息。如果沒有MessageProperties，它工作正常。 如何在MessageListenerAdapter的handleMessage中獲取MessageProperties？ public class EventMessageAdapter { public void ha

spring-amqp spring-rabbitmq 2016-08-29

---

1熱度

1回答

在SimpleMessageListenerContainer上使用addQueueNames需要更多時間

我們使用SimpleMessageListenerContainer（（max）consumer count爲75）。我們有一個用例，我們需要動態訂閱和取消某些隊列的訂閱，因此我們使用addQueueNames（）和removeQueueNames （）。當消費者數量爲75時，addQueueNames（）方法需要大約15秒才能完成。我們目前有大約200個隊列。我們想要經常添加和刪除監聽器中的隊列

rabbitmq spring-amqp consumer spring-rabbitmq 2016-07-26

---

0熱度

1回答

我正在使用MessageListener從指定的隊列中讀取消息，並希望在隊列中獲得消息後執行處理。在消息處理前一個消息處理期間，onMessage（）方法不處理下一消息

這裏是我的代碼 @Bean public MessageListenerContainer messageListenerContainer() { SimpleMessageListenerContainer messageListenerContainer = new SimpleMessageListenerContainer(); messageListenerCo

spring-amqp spring-rabbit spring-rabbitmq 2016-07-27

---

2熱度

1回答

春天rabbitmq測試 - RabbitListenerTestHarness沒有找到任何聽衆

我想寫一些春季rabbitmq應用程序的測試。 從documentation，我找到了使用RabbitListenerTestHarness的例子。 我創建了春天測試，看起來像： @RunWith(SpringJUnit4ClassRunner.class) @SpringApplicationConfiguration(classes = MyMain.class) public class

spring rabbitmq spring-test spring-rabbitmq 2016-08-01

---

3熱度

4回答

如何在春季啓動測試中模擬彈簧amqp /兔子

如何模擬春季rabbitmq/amqp，以便在嘗試自動創建交換/隊列時在Spring Boot Test期間不會失敗？ 鑑於我有一個簡單RabbitListener將導致隊列和交換被自動創建這樣的： @Component @RabbitListener(bindings = { @QueueBinding( value = @Queue(value = "myqueue

spring spring-test spring-amqp spring-rabbit spring-rabbitmq 2016-08-03

---

1熱度

2回答

使用spEL的Multiqueue RabbitListener

我以RabbitMQ開始我使用Maven創建了一個Spring Boot項目，而我正在使用Spring依賴關係來使事情發揮作用，但是，嘗試將隊列名稱外化的偵聽器並試圖使它「多隊列」，通過註釋： @RabbitListener(containerFactory = "rabbitListenerContainerFactory", queues = {"#{'${my.property.contai

java spring rabbitmq spring-amqp spring-rabbitmq 2016-06-15

---

2熱度

1回答

RabbitMQ java客戶端停止消費消息

我的應用程序從RabbitMQ消費一些消息並處理它們。 我有大約10個隊列，每個隊列有多達10個消費者（線程）。 我有一個預取5.我使用CloudAMQP插件（RabbitMQ作爲服務）在Heroku中運行我的設置。 我正在運行默認的心跳和連接超時設置（60秒）。 我的java應用程序是使用spring-rabbit庫的spring引導應用程序。 版本： RabbitMQ 3.5.3 Erlan

java heroku spring-boot rabbitmq spring-rabbitmq 2016-08-04

---

3熱度

1回答

增加春季兔子的心率值

我正在面對一些problems與我的設置，我試圖增加心跳間隔以測試可能的修復程序。 我使用 Spring boot 1.3.2.RELEASE Spring rabbit 1.5.3.RELEASE 和實例連接工廠的代碼是低於 RabbitConnectionFactoryBean connectionFactoryBean = new RabbitConnectionFactoryBean

java spring-boot rabbitmq spring-rabbitmq 2016-08-04

---

1熱度

1回答

在RabbitMQ集羣中停止MessageListenerContainer

我們在兩臺獨立的機器上創建了RabbitMQ集羣，消息生產者將消息發送到RabbitMQ負載平衡器。消息使用者也連接到RabbitMQ負載均衡器。 現在，我們希望特定隊列的監聽者暫停一段時間。我發現ListenerContainer的stop（）方法在這種情況下可能會有所幫助。但我想知道這是否會在兩個RabbitMQ實例上停止容器。 請注意，我無法在DEV/SIT上測試此功能，因爲集羣只能在UAT

rabbitmq spring-amqp spring-rabbit spring-rabbitmq 2016-08-19

---

1熱度

1回答

如何在Spring Rabbit中乾淨地關閉RabbitTemplate？

我寫了一個腳本，它使用Spring Rabbit將一些消息放在使用RabbitTemplate.convertAndSend的Rabbit隊列中，然後退出。但是，即使消息已入隊，Rabbit連接似乎仍可使應用程序保持活動狀態。我還沒有找到一種方式來清理告訴Rabbit服務器在消息排隊後停止。 我已經能夠想到的最佳解決方案是將我的convertAndSend調用更改爲convertSendAndRe

java spring rabbitmq spring-rabbit spring-rabbitmq 2016-08-19

---