MessageControllerDecorator

What it does

This decorator wraps the message queue controller to add special handling for asynchronous bulk operations.

It creates a lock on messages being processed and updates the operation's start time in the database within a transaction, ensuring data consistency when consumers process async tasks.

Public Methods

• lock()