spring-amqp

0熱度

1回答

我試圖關閉整個amqp安裝程序，以防止代理程序發生故障而無需關閉上下文/應用程序。我試圖從一個監聽器哪裏捕捉與從代理故障連接錯誤事件以下， connectionFactory.clearConnectionListeners(); connectionFactory.stop(); connectionFactory.destroy(); myContainer.stop(); myCon

1熱度

1回答

使用彈簧抽象的Rabbit MQ設計

我需要在哪裏偵聽來自名爲Metadata的隊列的消息 - 然後基於該消息，我將不得不讀取一些隊列讓它調用dataQ（該隊列的名稱將在元數據消息中）。爲了閱讀元數據，我可以使用兔子監聽器，但之後我必須從dataQ讀取其他消息，以便我可以手動進行拉動 - 但我希望有一些更像兔子監聽器那樣更乾淨，這樣我就不必管理頻道，ack等等。但是，直到我們從元數據隊列讀取消息之前，我們才知道隊列名稱，試圖探索其他

0熱度

1回答

waitForConfirmsOrDie vs PublisherCallbackChannel.Listener

我需要在spring的核心java實現中實現waitForConfirmsOrDie的影響。在覈心Java它是可實現的請求明智（channel.confirmSelect，設置強制性，發佈和Channel.waitForConfirmsOrDie（10000）將等待10秒）我實現template.setConfirmCallback（希望它與PublisherCallbackChannel.Li

-1熱度

1回答

請告訴我SpringAMQP支持的RabbitMQ版本1.7

請告訴我SpringAMQP 1.7.0RELEASE支持的RabbitMQ版本。（SpringAMQP 1.7.0RELEASE支持RabbitMQ的版本爲教育版）我不明白我看到了這個文檔。我正在使用SpringBoot 1.5.1。

1熱度

1回答

SpringBoot：手動確認多個AMQP消息

我需要在成功處理並存儲後，才能在兔子聽衆中手動確認多條消息。使用的彈簧啓動配置如下 listener: concurrency: 2 max-concurrency: 20 acknowledge-mode: manual prefetch: 30 消息應該一次存儲20個批次。只有當它們被成功存儲時，才應該發送多重確認。存儲機制也存在關聯超時，即使沒有2

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的應用（按Ctrl-C）

我試圖找出什麼是安全地停止RabbitMQ的一個應用正確的方式，如果它是由如Ctrl-C或正常關機中斷中斷是否足夠我有一個ApplicationContext.close（帶有一個註冊的鉤子），這將隱含地關注從ConnectionFactory到Listeneres的完整正常關閉？我試圖執行摧毀了在一些博客中只提到聽衆當我有這樣 <rabbit:listener-container conn

0熱度

2回答

在Weblogic 12.2.1上使用Spring AOP與JMS模板上的動態代理時出錯12.2.1

當我嘗試在同一個項目中使用時出現錯誤Spring Template JMS將消息傳遞給ActiveMQ和Spring AOP以審計和處理Weblogic上的異常12.2.1。服務器啓動時發生錯誤。如果我配置方面使用CGLIB，我從Weblogic得到異常，我更喜歡，如果有可能保持使用動態代理。有沒有人有這個問題或有任何想法可能會導致它？我的方面配置類： @Configuration @Ena

1熱度

1回答

RabbitMQ的HA部署，以避免丟失的消息

我設置了2個節點的消息鏡像具有以下策略3個節點集羣的RabbitMQ： ha-mode: exactly ha-params: 2 ha-sync-mode: automatic 我正在使用Spring引導和Spring AMQP一些性能測試。基本上我已經阿帕奇JMeter的發送HTTP請求到發佈的消息的控制器： @RequestMapping(value = "/webhook", me