processLockPool moves messages from the lock message pool to the message pool.

ProcessTimeoutMessages process messages timeout that have not been acked (or nacked) for more than 5 minutes returning them back to the active queue with the maximum score.

RecoveryMessagesPool recover messages pool sending all storage data to cache.

Checks if there is any queue with max_elements configuration and then remove every exceeding messages using expiry_date to sort which elements will be removed TODO manage message pool update individually by queue to avoid future bottlenecks.

Remove 10000 expired elements ordered by expiration date asc for each queue.