spring-amqp

2熱度

1回答

條件： 1）使用休眠事務管理器 2）隊列被標記爲事務 3）使用自帶束帶有彈簧AMQP的SimpleMessageListenerContainer一樣來觸發的消費者信息。情形：消費者生成異常由於一些意想不到的錯誤導致休眠事務回滾，並且該消息被重新排隊。這由容器照顧。由於SimpleMessageContainer的寫入方式，我找不到從隊列中刪除消息的方法，並且&有平臺事務管理器回滾。通道&事

9熱度

2回答

沒有連接的AMQP/RabbitMQ頻道何時死亡？

我有一個簡單的RabbitMQ測試程序隨機排隊消息，另一個讀取它們，全部使用Spring-AMQP。如果消費者死亡（例如，在沒有機會關閉其連接或通道的情況下殺死一個進程），則任何未被確認的消息似乎永遠都不會被確認。我見過很多參考文獻（例如this question），表示通道在沒有連接的情況下死亡，剩餘的未被刪除的消息將被重新發送。這不是我看到的行爲 - 相反，我獲得了越來越多的標記爲IDLE的

0熱度

1回答

Spring框架中的StatefulRetryOperationsInterceptor類的問題

我有類StatefulRetryOperationsInterceptor的問題，因爲我不知道如何使用它，因爲Internet上沒有任何源代碼示例，所以我請求你幫忙:)。所以，如果你有任何這個類的使用經驗，請你可以在這裏發佈一些簡單的源代碼示例，我將不勝感激。謝謝

6熱度

2回答

我如何知道我的消息是使用spring amqp成功發送的？

我正在使用RabbitTemplate類寫入使用spring amqp的RabbitMQ隊列。我使用convertAndSend方法將消息發送到隊列。這在正常情況下運行良好，但如果隊列不存在，它似乎無聲無息地失敗。不會引發異常，也不會將錯誤/調試消息記錄到記錄器中。對於我來說，確保郵件傳遞的最佳方式是什麼？下面是當前代碼正在執行的一個示例。 RabbitTemplate template =

5熱度

1回答

Spring AMQP/RabbitMQ和Hibernate Transaction Mananger

我有一個使用Hibernate和PostgreSQL的Spring應用程序。它也使用Spring AMQP（RabbitMQ）。我使用配置Hibernate的事務管理器如下： <bean id="transactionManager" class="org.springframework.orm.hibernate3.HibernateTransactionManager"

1熱度

1回答

使用Spring AMQP的Web應用程序是一個客戶端？

嗨，我想知道如果我創建一個使用Spring AMQP的webapp。那是單一的webapp 1 AMQP客戶端嗎？或者是由用戶產生的任何請求導致AMQP呼叫客戶端，因此可能有x個客戶端？

0熱度

2回答

如何通過Spring/AMQP /兔子聽數千IMAP IDLE的收件箱

的使用情況是有一個服務器連接到上千用戶的電子郵件帳戶和嗅探收到的郵件中的Java最好用Java郵件和Spring的集成/ AMQP /兔MQ鍵入可擴展的基礎架構..並根據需要添加imap空閒類型連接並添加服務器處理節點。單入站通道很容易與IMAP IDLE站適配器..你可以配置XML很少。但是，如果您需要一個持久的偵聽器/ imapidlechannel適配器隊列中的數千個這些適配器，並且需要爲

0熱度

2回答

存儲/序列化列表爲消息彈簧AMQP

我是使用RabbitMQ的Spring AMQP的新手。我明白這個問題涉及更廣泛的問題。我想將對象列表存儲到可發送給消費者的消息中。任何人都可以提供這個問題的簡單解決方案？我知道序列化可以是一個解決方案，但這對於我正在使用的簡單應用程序來說是一種矯枉過正。這些消息本質上是異步的。還有其他方法嗎？