Architektur
Die Engine folgt einer strikten Schichtenarchitektur. Jede Schicht kommuniziert nur mit der direkt darunterliegenden Schicht.
Schichtenarchitektur
Schicht-Beschreibungen
| Schicht | Verantwortung |
|---|---|
| EngineServer | Express-App, Socket.IO, Middleware-Stack, CORS, Security-Header |
| Router | Routing-Konfiguration, Worker-Prozess-Management |
| API | REST-Controller (HTTP-Endpunkte), API-Services (Geschaeftslogik-Delegation) |
| Core | BPMN-Element-Handler, Prozessausfuehrung, Event-Handling |
| Infrastruktur | Datenbank-Adapter, Event-System, Extension-Loading, Auth |
Request-Flow
Ein HTTP-Request durchlaeuft den Middleware-Stack und wird an den zustaendigen Worker-Prozess delegiert:
Worker-Prozesse
Die Engine trennt Lese- und Schreiboperationen in separate Worker-Prozesse fuer bessere Performance und Isolation:
Der Runtime Worker verarbeitet alle schreibenden Operationen (Prozess starten, Task abschliessen). Der Query Worker verarbeitet alle lesenden Operationen (Prozessinstanzen auflisten, Details abrufen).
Event-System
Der EventAggregator ist das zentrale Kommunikationssystem der Engine. Er verteilt Events In-Process ueber ein Pub/Sub-System.
Event-Patterns
| Pattern | Methode | Beschreibung |
|---|---|---|
| Work Queue | publishToWorkQueue() | Competing Consumers — nur ein Subscriber erhaelt die Nachricht |
| Topic mit Routing Key | publishToTopicWithRoutingKey() | Pub/Sub mit Routing — Nachrichten werden nach Key gefiltert |
| Broadcast | publishToBroadcast() | Alle Subscriber erhalten die Nachricht |
| Internal | publishInternal() | Immer In-Process |