Confirmation that a message was processed.

Component producing streaming data.

Converting one message format to another.

Deliberately limiting resource usage.

Indication that message processing failed.

Storing state changes as events.

Adding information to a message.

Maximum allowed resource usage.

Attempt to process a failed message again.

Reprocessing stored events.