retrypolicy

    -1熱度

    2回答

    我正在使用用C#編寫的客戶端應用程序向羣集交換服務器發送批量電子郵件。 它可以發生,它做到了,客戶端應用程序超時(而不是服務器)。 由於無法知道服務器是否完成了請求,因此如何處理這種情況下的重試? 沒有參與IDS,可能是使用,以避免重複。 設置長時間超時甚至無限超時並不是一個好策略。 我使用重試指數退避算法。在這種情況下,它應該只發送一個副本,因爲它將在下次等待更長時間。 我認爲沒有子彈教授解決方

    2熱度

    1回答

    後,這是我的代碼配置Azure存儲帳戶 public CloudTableClient ConfigureStorageAccount() { var storageCred = new StorageCredentials(ConfigurationManager.AppSettings["SASToken"]); CloudTableClient = new Clo

    1熱度

    1回答

    我需要配置通過ExecutorCompletionService調用API的重試策略。 示例代碼: public void func() throws Exception{ ExecutorService executorService = Executors.newFixedThreadPool(5); CompletionService<String> completion

    0熱度

    1回答

    當我們有一段代碼經常失敗並且必須重試時。然後我們使用重試模式。 try { //do request here } catch (Exception e) { //wait for some millisecond and retry retry(); } 我們通常推遲一些毫秒之前重試該請求。我想知道爲什麼我們需要一些延遲?如果重試請求未等待並再次發送請

    0熱度

    2回答

    我正在使用客戶端寫入cassandra(api:com.datastax.driver.core) 如果在連接完成後關閉cassandra clustures。我的日誌中出現以下錯誤 2015-11-05 12:08:21,667 ERROR [Reconnection-1] com.datastax.driver.core.ControlConnection - [Control connect

    1熱度

    1回答

    我正在研究一項要求,要求我在成功獲取某些數據後調用特定的端點。我們使用發佈到SQS隊列的SNS主題實現了這一目標,SQS隊列又調用端點。 SNS - > SQS - >我的端點(進程Q消息) - >調用外部端點來獲取數據。 現在,我們發現訂單處理後數據不可用,現在需要每隔30秒繼續嘗試5次。 有什麼辦法可以做到這一點? 現在,我做了這樣的事情,使得從隊列處理消息的我的端點始終返回錯誤,以便重試消息

    0熱度

    1回答

    我試圖從一個空的blob容器中下載文件,並按預期得到了404。問題是我在fiddler中看到的這個文件只有1個調用,而不是3個(正如我在RetryPolicy中指定的那樣),我也注意到調用在1秒內完成,因此在再次嘗試之前它肯定沒有等待10秒。 .. 如何知道BlobClient是否真的重試了? var blobClient = this.storageAccount.CreateCloudBlob

    0熱度

    1回答

    邏輯應用程序文檔here指示邏輯應用程序支持使用以下"input" "retryPolicy" : { "type": "<type-of-retry-policy>", "interval": <retry-interval>, "count": <number-of-retry-attempts> } 的文檔狀態重試HTTP操作策略: 的重試間

    1熱度

    1回答

    Spring的@Retryable註釋將重試三次(默認)並回退到@Recovery方法。然而,@CircuitBreaker會在狀態關閉時重試一次並回退。 我想結合這兩個:當斷路器的狀態是閉合的,在回退之前會重試三次(處理瞬態錯誤),如果狀態是開放的,會直接回退。 任何優雅的方式來做到這一點?一種可能的方法是在函數內部實現重試邏輯,但我覺得這不是最好的解決方案。

    0熱度

    2回答

    不確定我的Service Bus 1.1的重試策略邏輯有什麼問題。我們無法使用Azure服務總線。我嘗試了幾種不同的配置,但仍然沒有運氣讓它着火。它只會移動到例外。 TokenProvider provider = TokenProvider.CreateSharedAccessSignatureTokenProvider("RootManageSharedAccessKey", "<key go