spring-amqp

2熱度

1回答

立足我的建築離這個例子： RabbitMQ - Work Queues 設置：工人同時得到一個消息，每個勞工下載量文檔，需要幾秒鐘工人成功下載文檔後，它會確認郵件如果工人不能下載一個文件，它爲noAcks重新排隊（三級重試的最大值）我期待到我的實現的瓶頸是造成減速的消息。因爲我使用noAck來重新排隊失敗的工人。要啓用此均勻地分佈在我的工作線程我已經設置預取1.Looking在這個問題：

1熱度

1回答

春季集成AMQP和RabbitMQ丟失和「unacked」消息

我試圖創建2個簡單的應用程序;一個是將消息發佈到RabbitMQ頻道，另一個是從頻道接收它並將其打印出控制檯。發件人應用程序立即啓動併發布10條消息。我在客戶端控制檯上看到的只有大約一半的消息打印出來。當我檢查RabbitMQ Web客戶端時，我還會看到其中一條消息始終處於「未定義」狀態。當我閱讀文檔時，據我瞭解「amqp入站/出站網關」是實現此目的的一種簡單方法。你能幫我理解爲什麼我丟失

1熱度

1回答

應用上下文被關閉且連接工廠不能再創建連接彈簧AMQP

我已經實現多線程以執行JIRA一些操作一旦我消耗來自RabbitMQ的消息。我使用的彈簧AMQP（版本1.6.1）一旦線程捕獲該異常，我設置爲錯誤和輸出對象我在未來的參考地位。將此輸出對象發送到隊列時。我對着上面execption 代碼：連接工廠： @Configuration @PropertySources({ @PropertySource("classpath:application

1熱度

1回答

連接拒絕嘗試從Cloud Foundry讀取RabbitMQ隊列使用Spring

我試圖使用RabbitMQ從一個應用程序發佈消息並在另一個應用程序中接收它們。這些應用程序託管在Cloud Foundry上，並且都綁定到RabbitMQ的相同實例。我能夠從第一個應用程序發送消息到隊列，但在我的第二個應用程序中，它使用@RabbitListener和@RabbitHandler來偵聽此隊列，我得到了一個Connection Refused錯誤。不過，它在我本地的RabbitMQ

1熱度

1回答

我們可以更改rabbitmq的屬性spring配置和流的兔子

在我的POC中，我使用Spring Cloud Config和Spring Stream Rabbit。我想動態地改變監聽器的數量（併發性）。有可能這樣做嗎？我想這樣做以下： 1）如果在隊列中的郵件太多，我想增加併發級別。 2）在方案中，其中我的下游系統不可用時，我想停止處理從隊列中的消息（在短併發級別0）。我怎麼能做到這一點？感謝您的幫助。

1熱度

1回答

彈簧集成 - 將完整的消息保存到數據庫並再次讀取

是否有可能將完整的消息序列化爲某種格式JSON並將其保存到數據庫。在此之後，我會用完整標題將消息反序列化並將其發送給amqp。喜歡的東西： <int:object-to-json-transformer object-mapper="mapper" /> <int-jdbc:outbound-channel-adapter channel="srk2" data-source="dataSour

1熱度

1回答

@HystrixCommand彈出微服務問題

我們在Spring Boot/Cloud微服務中遇到Hystrix Command的問題。我們有一個Spring組件，其中包含一個註解爲@RabbitListener的方法。當新消息到達時，該方法將調用委託給NotificationService::processNotification()。 NotificationService是一個註釋爲@Service的bean。方法processNoti

0熱度

1回答

spring-amqp RabbitMQ動態更改發佈商確認

有沒有更改發佈商確認每條消息的方法？我們有一個接收消息併發布到RabbitMQ的休息層。根據某些消息屬性，我們決定是否需要發佈商確認。有沒有辦法重寫，發佈者確認發送消息？

0熱度

1回答

Rabbitmq：優先消費來自多個隊列的消息

如果我有兩個隊列用於消費消息，並且我使用一個SimpleMessageQueueListenerContainer作爲消息，那麼當兩個隊列中都有消息時，將以何種順序調用偵聽器？我會嘗試更具體，我的工作對這個問題的：我有一個需要從2個隊列消費消息的消費者應用程序 - 比如定期的作業隊列和偶發的作業隊列。如果'infrequent-jobs-queue'中有任何消息，我想在消費'regular-j

2熱度

2回答

春季整合AMQP - 儘管重試建議不斷重試

我以前用JMS非常成功地使用過Spring集成，但現在我們正在使用RabbitMQ/AMQP並且在處理錯誤時遇到了一些問題。我有一個int-amqp：入站通道適配器與errorChannel設置爲接收任何異常，在這裏ErrorTransformer類檢查失敗的消息的原因異常。然後，根據例外任一類型： - 抑制異常，並轉換成一個JSON對象，可以去AMQP出站通道適配器作爲企業回覆解釋的失敗。在這