MessageQueue
MessageQueue
The MessageQueue block can be used to queue incoming (In) events (i.e. messages with data) to be emitted to the output (Out) one-by-one, on Next event.
Usage
MessageQueue is a useful helper block to add guaranteed one-by-one processing for incoming events to avoid new event processing to be started before the previous event is fully processed.
Input and Output Events
| Name | Input or Output | Description |
|---|---|---|
| Init | Input | Instructs to clear message queue, then emits Inited |
| Inited | Output | Will be emitted after Init is done |
| In | Input | Input events to be queued should be sent here |
| Out | Output | Output events will be outputted via this one-by-one |
| Next | Input | When Out message processing is finished, then this message should be sent to let the MessageQueue block know that it can emit another pending message to Out. When no pending events are in queue Empty will be emitted instead. |
| Empty | Output | Will be emitted in response to Next when there are no more pending events in queue |
Get started with CDP Studio today
Let us help you take your great ideas and turn them into the products your customer will love.