spring-retry

    1熱度

    2回答

    我正在對另一個服務進行REST調用以保存數據庫上的項目。數據非常重要,所以我們不能承受任何損失。 如果網絡出現問題,此消息將會丟失,而這種情況不會發生。我已經搜索了關於Spring Retry的信息,並且我看到它旨在處理暫時的網絡故障,這不是我所需要的。 我需要一種方法把某種隊列(如Active MQ)的REST調用和維護秩序(因爲我得到保存,刪除,這是非常重要的,更新REST調用。) 任何想法?

    1熱度

    1回答

    我的設置: 我有一個消息守護進程使用ActiveMQ將消耗JSON消息。 JSON消息的發佈者添加了具有值的type頭,例如,com.example.Foo這是json消息的類型。我用這個將json轉換成pojo。 Spring配置: 一旦接收到消息,這些都是它通過以下步驟: 1.變壓器:來變換JSON來POJO 2.淨荷類型路由器:基於POJO的類型,將pojo路由到適當的服務激活者。 3.服務

    3熱度

    1回答

    是否可以根據特定條件重試?如果我使用Retryable進行註釋,它將根據某些異常重試,但如果捕獲該異常並滿足相應的條件,我想重試。 實施例: @Retryable(value={MyException.class},maxAttempts=2) public myMethod(Request request){ try{ doSomething(); } Cat

    1熱度

    1回答

    是否可以根據錯誤狀態碼在春季重試中設置RetryPolicy?例如我不想在HttpStatus.BAD_REQUEST狀態碼爲400時重試HttpClientErrorException。因此,它應該忽略所有其他錯誤碼 - 4XX。 我正在使用Spring集成http outboundGateway調用服務器。 現在在我RequestHandlerRetryAdvice我作爲 SimpleRetr

    0熱度

    1回答

    我找不到任何有關我需要的操作可能性的信息。我正在使用@Retry處理方法使用@Retryable註釋。 Smth像這樣: @Retryable(value = {Exception.class}, maxAttempts = 5, backoff = @Backoff(delay = 10000)) public void update(Integer id) {

    0熱度

    1回答

    在Spring Core Advice API docs有兩種意見的定義: 每個類的建議 - 這一定不是「依賴於代理對象的狀態或添加新的狀態」 基於實例的通知 - 即「添加狀態到被代理對象」 RequestHandlerRetryAdvice,每次的javadoc,有一個無狀態和操作的狀態模式。 在哪些情況下可以使用RequestHandlerRetryAdvice作爲每個類的建議? (即使用單個

    0熱度

    1回答

    我想測試,如果我的方法調用被重試幾次,如果發生一些異常。如果我直接調用方法,它可以正常工作。但是如果我在單獨的線程中調用它,我的測試方法失敗,它不會看到任何重試嘗試。 這是我的方法: public class MyClass { @Inject private ServiceClass service; @Retryable(value = {Exceptio

    0熱度

    1回答

    當我在@Transactional和@Retryable(value = StaleStateException.class) method foo()的末尾發佈CustomEvent時,它是如何處理的? 如果我在方法執行後提交期間得到StaleStateException,那麼@TransactionalEventListener(phase = TransactionPhase.AFTER_C

    1熱度

    1回答

    我發佈消息到RabbitMQ的,我想跟蹤誤差時RabbitMQ的下跌,爲了這個,我增加了一個RetryTemplate與恢復回調,但回調的恢復只提供此方法getLastThrowable()和我不確定如何提供RabbitMQ關閉時失敗的消息的詳細信息。 (按照文檔「的RecoveryCallback有一定的限制,該重試上下文只包含 lastThrowable場。對於更復雜的使用情況下,你應該使用一

    2熱度

    2回答

    我已經使用Spring聲明重試在我的項目像 @Service class Service { @Async @Retryable(maxAttempts=12, [email protected](delay=100, maxDelay=500)) public service() { // ... do something } } 現在,我有兩個