Pool

An Event Aggregator-Selector

The Aggregator-Selector functions pretty much like an event pool. The actor receives two types of events.

• Event stream

• Selection list event

The actor receives a stream of messages from the event broker and temporarily stores them in its internal buffer until an event containing an event list is received. If all the selected events are available, the actor will pack them into a new event and send it back to the event broker; otherwise, the actor will wait until they are available in the buffer.

Usage

The actor possesses important properties and has potential uses.

Stateful Aggregation: The Pool actor can maintain state information about the events it has received. This allows it to make decisions based on the history of events and perform stateful aggregation.

Batch Processing: The Pool actor can be used for aggregating events over a certain period before processing them as a batch. This is useful in scenarios where it's more efficient to handle multiple events collectively.

Event Filtering and Grouping: The actor can filter incoming events based on certain criteria and group them together. For example, it might collect events related to a specific category or topic and process them as a unit.