wip

Author: soccermax

docs/configure-event/index.md

@@ -41,7 +41,7 @@ they should be processed.
 ## Parameters
 
 | Property                      | Description                                                                                                                                                                                                                                                                                                                                                                                                                               | Default Value   |
-| ----------------------------- | ----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------- | --------------- |
+|-------------------------------| ----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------- | --------------- |
 | impl                          | Path of the implementation class associated with the event.                                                                                                                                                                                                                                                                                                                                                                               | -               |
 | type                          | Specifies the type of the event.                                                                                                                                                                                                                                                                                                                                                                                                          | -               |
 | subType                       | Specifies the subtype of the event, further categorizing the event type.                                                                                                                                                                                                                                                                                                                                                                  | -               |
@@ -58,6 +58,7 @@ they should be processed.
 | appNames                      | Specifies the application names on which the event should be processed. The application name is extracted from the environment variable `VCAP_APPLICATION`. If not defined, the event is processed on all connected applications.<br><br>- Supports regex patterns in the format `/pattern/flags` (e.g., `/srv/i` for case-insensitive matching).<br>- If the value is **not** a regex, it is treated as a string and must match exactly. | null            |
 | appInstances                  | Specifies the application instance numbers on which the event should be processed. The instance number is extracted from the environment variable `CF_INSTANCE_INDEX`. If not defined, the event is processed on all instances of the connected applications.                                                                                                                                                                             | null            |
 | retryFailedAfter              | The duration (in milliseconds) after which failed events should be retried, provided the retry limit has not been exceeded.                                                                                                                                                                                                                                                                                                               | `5 * 60 * 1000` |
+| retryOpenAfter                | The duration (in milliseconds) after which failed events should be retried, provided the retry limit has not been exceeded.                                                                                                                                                                                                                                                                                                               | `5 * 60 * 1000` |
 | multiInstanceProcessing       | (Currently applicable only for Single Tenant) Allows processing of the same event type and subtype across multiple application instances.                                                                                                                                                                                                                                                                                                 | false           |
 | increasePriorityOverTime      | After three minutes, the priority of unprocessed events is increased by one. This behavior can be disabled with this option. The behavior is documented [here](#priority-of-events).                                                                                                                                                                                                                                                      | true            |
 | keepAliveInterval             | Specifies the interval (in seconds) at which keep-alive signals are sent during event processing to monitor system health.                                                                                                                                                                                                                                                                                                                | 60              |

src/EventQueueProcessorBase.js

@@ -41,6 +41,7 @@ class EventQueueProcessorBase {
   #isPeriodic;
   #lastSuccessfulRunTimestamp;
   #retryFailedAfter;
+  #retryOpenAfter;
   #keepAliveRunner;
   #currentKeepAlivePromise = Promise.resolve();
   #etagMap;
@@ -69,6 +70,7 @@ class EventQueueProcessorBase {
       this.__parallelEventProcessing = LIMIT_PARALLEL_EVENT_PROCESSING;
     }
     this.#retryFailedAfter = this.#eventConfig.retryFailedAfter ?? DEFAULT_RETRY_AFTER;
+    this.#retryOpenAfter = this.#eventConfig.retryOpenAfter ?? DEFAULT_RETRY_AFTER;
     this.__concurrentEventProcessing = this.#eventConfig.multiInstanceProcessing;
     this.__retryAttempts = this.#isPeriodic ? 1 : this.#eventConfig.retryAttempts ?? DEFAULT_RETRY_ATTEMPTS;
     this.__selectMaxChunkSize = this.#eventConfig.selectMaxChunkSize ?? SELECT_LIMIT_EVENTS_PER_TICK;

src/config.js

@@ -60,6 +60,7 @@ const ALLOWED_EVENT_OPTIONS_AD_HOC = [
   "processAfterCommit",
   "checkForNextChunk",
   "retryFailedAfter",
+  "retryOpenAfter",
   "multiInstanceProcessing",
   "kind",
   "timeBucket",