Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Extend CAP Outbox Service to support more event-queue features #288

Open
2 tasks
oklemenz2 opened this issue Feb 14, 2025 · 2 comments
Open
2 tasks

Extend CAP Outbox Service to support more event-queue features #288

oklemenz2 opened this issue Feb 14, 2025 · 2 comments
Assignees
Labels
enhancement New feature or request outbox

Comments

@oklemenz2
Copy link

oklemenz2 commented Feb 14, 2025

Features

  • periodic events via periodic section
  • custom functions like cluster

The following configuration shall be possible in event.queue CDS ENV:

Example:

"SchedulingProcessingService": {
  "impl": "./srv/scheduling/provider-service",
  "outbox": {
    "kind": "persistent-outbox",
    "maxAttempts": 5,
    "checkForNextChunk": true,
    "parallelEventProcessing": 5,
    "periodic": {
        "main": {
          "cron": "0 0 0 * * *"
        },
        "process": {
           "...": "..."
        }
    }
  }
}
@oklemenz2
Copy link
Author

oklemenz2 commented Feb 14, 2025

Bootstrap event-queue. Connect to every service with outbox to inject event-queue handling... Default: autoConnect: true Can be deactivated autoConnect: false

@oklemenz2 oklemenz2 changed the title Periodic Events via CAP Outbox Periodic Events via CAP Outbox Service Feb 14, 2025
@soccermax soccermax added the enhancement New feature or request label Feb 17, 2025
@soccermax soccermax self-assigned this Feb 18, 2025
@soccermax soccermax changed the title Periodic Events via CAP Outbox Service Extend CAP Outbox Service to support more event-queue features Feb 18, 2025
@soccermax
Copy link
Contributor

Support of custom event-queue functions

Can be done like this

  // clusterQueueEntries + msg.event
  // clusterQueueEntries
  // super.clusterQueueEntries(queueEntriesWithPayloadMap);

  // onCommitError + msg.event
  // onCommitError
  // super.onCommitError(queueEntriesWithPayloadMap);

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
enhancement New feature or request outbox
Projects
None yet
Development

No branches or pull requests

2 participants