Combiner

The Combiner is a special actor to aggregate multiple events into a single one. The Combiner has an internal buffer to store out-of-sequence messages until a complete sequence of events is received. This actor can handle a stream of messages that may arrive out of order. Finally, the messages are grouped together and published back to the event broker. Similar to other built-in actors, a Combiner does not alter the contents of the messages.

Usage

The actor can be used for managing the sequencing of events. In Streamer, events are generated and emitted by multiple producers. Due to its distributed nature, events may arrive at the event broker out of order. The combiner actor can function as a standard resequencer to reorder the events it receives.