Example

.png>)

A new order arrives on , gets sent to the NEW Consumer who, on success, will create a new message on ORDERS.processed. The message again enters the Stream where a DISPATCH Consumer receives it and once processed it will create an ORDERS.completed message which will again enter the Stream. These operations are all based meaning they are work queues and can scale horizontally. All require acknowledged delivery ensuring no order is missed.

As messages are acknowledged to the NEW and Consumers, a percentage of them are Sampled and messages indicating redelivery counts, ack delays and more, are delivered to the monitoring system.