File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -9,12 +9,7 @@ class LibCurl extends QueueConsumer
99 protected string $ type = 'LibCurl ' ;
1010
1111 /**
12- * Send a batch of messages to the API with spec-compliant retry logic:
13- * - 2xx/3xx: success
14- * - 429 + Retry-After: sleep without consuming retry budget
15- * - 429 without Retry-After / other retryable (5xx except 501/505/511,
16- * 408/410/460): exponential backoff, counts against retry budget
17- * - Non-retryable 4xx / 501/505/511: drop immediately
12+ * Send a batch of messages to the API with retries on error
1813 *
1914 * @param array $messages array of all the messages to send
2015 * @return bool whether the request succeeded
@@ -35,7 +30,7 @@ public function flushBatch(array $messages): bool
3530 $ library = $ messages [0 ]['context ' ]['library ' ];
3631 $ userAgent = $ library ['name ' ] . '/ ' . $ library ['version ' ];
3732
38- $ backoffMs = 500 ; // base 500ms per e2e spec
33+ $ backoffMs = 500 ; // base 500ms per spec
3934 $ backoffCapMs = 60000 ; // cap 60s
4035 $ retriesRemaining = $ this ->retry_count ;
4136 $ attempt = 0 ;
You can’t perform that action at this time.
0 commit comments