spring-rabbit

0熱度

1回答

我觀察奇怪的行爲，而這樣做的RabbitMQ 3.3.5的POC使用彈簧兔1.3.9.RELEASE庫當我開始一個單一的生產線，事情順利進行。但是，如果同時啓動多個線程，只有其中一個線程完成，所有其他線程無限期地被阻塞，即使在隊列變空之後。從rabbitmqctl list_connections進行監視時，被阻止的線程連接的狀態仍保持運行狀態。應該注意的是，當生產者阻止時，或者在整個運行期間

1熱度

1回答

Spring SimpMessagingTemplate

我有一個應用程序從RabbitMQ接收一些數據。一切工作正常，我的意思是在課堂上我有註解@EnableScheduling。 @Scheduled(fixedDelay = 5000) public void volumeGraphData() { Random r = new Random(); Graph graph = new Graph(); graph

3熱度

1回答

RabbitMQ的自定義目的地

我想在我的項目中使用RabbitMQ作爲代理，我想在客戶端打開套接字時分配目標隊列。事情是這樣的：http://i.imgur.com/ldB2M0m.png 我設法與SimpleBroker做到這一點，但是當我嘗試用StompBrokerRelay我不能assing上RabbitMQ的隊列中來做到這一點，我停止客戶端（http://i.imgur.com/gNaRHCQ.png）上接收消息。

1熱度

2回答

如何決定使用消息傳遞（例如RabbitMQ）與Web服務進行後端組件交互/通信？

在開發後端組件時，我需要決定這些組件如何相互交互和通信。特別是，我需要決定使用（RESTful，微型）Web服務還是使用消息代理（如RabbitMQ）更好。是否有某些標準可以幫助您在每個組件與消息傳遞之間決定使用Web服務？

2熱度

1回答

提取頭沒有標註

申報隊列現在我可以這樣做： @RabbitListener(queues = {ENTITY_KEY + "-snapshots", ENTITY_KEY + "-updates"}) public void handleMessage(ProviderOddsOffer offer, @Header("update_type") Long updateType) { ... }

0熱度

1回答

在多線程環境中沒有修復發送到Rabbitmq服務器的消息的順序環境

請先查看我的代碼。這是我的測試類這是創建2000線程和那些線程正在發送消息。 public class MessageSenderMultipleThreadMock { @Autowired MessageList message; @Autowired MessageSender sender; public boolean process

0熱度

1回答

處理髮布者確認超時在春季AMQP-RabbitMQ

我正在測試AMQP的Spring RabbitMQ實現，並且我想使用發佈者確認。我從文檔和代碼中遺漏的是我應該如何處理某個年齡段未經確認的消息。裸露的RabbitMQ客戶端java庫提供了一個很好的Channel.waitForConfirmsOrDie(timeout)方法，但那樣會迫使我在Spring抽象下變得更深，爲什麼我不想繼續發佈和重試未經確認的消息？（順便說一句，如果可以使用spr

3熱度

1回答

帶RabbitMQ的spring-amqp沒有正常關機

當消費者在SimpleMessageListenerContainershutdownTimeout之後沒有完成執行時，我的Spring應用程序被掛起。監聽器： public class LongRunningMessageListener implements MessageListener { @Override public void onMessage(Messag

2熱度

1回答

在RabbitMQ配置消費者取消

我們正在使用帶有鏡像隊列的雙節點活動 - 活動RabbitMQ羣集。使用鏡像策略：「policies」：[{「vhost」：「/」，「name」：「ha-all」，「pattern」：「」，「apply-> to」：「all」，「definition」：{「ha-mode」：「all」，「ha-sync-mode」：「automatic」}，「priority」：0}] 版本：RabbitMQ

5熱度

2回答

嘗試遷移從<rabbit:> xml名稱空間配置爲java @Configurable不能複製

我想從XML Spring amqp配置遷移到基於java的註釋，因爲它「更簡單」。不知道我在做什麼錯了XML配置工作正常，但java @Configurable拋出「由java.net.SocketException異常：連接重置」異常。 XML配置（完美的作品）： <?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.