
Event processing
The Events Gateway system is responsible for receiving and processing events from various sources, such as the FlowX Engine and Task Management. It acts as an intermediary between these systems and the rest of the system components.It is a reusable component and is also used in administration scenarios to provide feedback without a refreshβfor example, misconfigurations in platform version 4.1, allowing an error to be displayed in real-time during configuration.
Message distribution
The Events Gateway system reads messages from the Kafka topic (messaging_events_topic
) and distributes them to relevant components within the system. It ensures that the messages are appropriately routed to the intended recipients for further processing.
Event publication
The Events Gateway system plays a crucial role in publishing events to the frontend renderer (FE renderer). It communicates with the frontend renderer usingHTTP
via WebFlux
. By publishing events, it enables real-time updates and notifications on the user interface, keeping the user informed about the progress and changes in the system.
It is designed to efficiently send updates to the frontend in the following scenarios:
- When reaching a specific User Task (UT), a notification is sent to ensure the corresponding screen is rendered promptly.
- When specific actions require data to be sent to the user interface from a node.
Integration with Redis
Redis plays an important role within the platform. It handles every message and is mandatory for the platform to function correctly, especially with the frontend. The platform relies on Redis to ensure that the messages are distributed efficiently and that the correct instance with the SSE connection pointer for the recipient is always reached.