1.22.0

Included commits: 1.21.1...1.22.0

Improvements

• Introduced resource-aware queue worker to enable dynamic queue processing based on available system resources and queue metrics.
• Added queue scanning capability with QueueScanner to monitor queue sizes and prioritize processing based on configurable modes.
• Introduced QueueReadModeEnum with multiple processing modes to control worker behavior for handling publish, sync, big, and small queues.
• Added system resource monitoring with SystemResourcesManager to track memory usage and prevent worker process overload.
• Extended QueueDynamicSettingsTransfer, QueueMetricsRequestTransfer, and QueueMetricsResponseTransfer to support queue metrics collection and dynamic configuration updates.

1.21.1

Included commits: 1.21.0...1.21.1

Fixes

• Adjusted QueueFacade::startWorker() so it does not throw the ProcessTimedOutException exception when the process execution exceeds 60 seconds.

1.21.0

Included commits: 1.20.0...1.21.0

Improvements

Added support for new spryker/gui:4.0.0.

1.20.0

Included commits: 1.19.0...1.20.0

Improvements

• Adjusted QueueWorkerConsole::execute() to enhance queue worker console output for better debugging visibility.

1.19.0

Included commits: 1.18.0...1.19.0

Improvements

• Introduced QueueReceiveMessage.isRetryExist transfer field to indicate retry queue availability.
• Adjusted QueueFacade::startTask() to set retry availability flag on messages before processing.
• Adjusted QueueFacade::startTaskWithReport() to set retry availability flag on messages before processing.
• Added error logging when queue processes fail to start or exit immediately.

1.18.0

Included commits: 1.17.0...1.18.0

Improvements

• Introduced QueueReceiveMessage.isRetryExist transfer field to indicate retry queue availability.
• Adjusted QueueFacade::startTask() to set retry availability flag on messages before processing.
• Adjusted QueueFacade::startTaskWithReport() to set retry availability flag on messages before processing.
• Added error logging when queue processes fail to start or exit immediately.

1.17.0

Included commits: 1.16.0...1.17.0

Improvements

• Updated transfer fields with description.

1.16.0

Included commits: 1.15.0...1.16.0

Improvements

• Added PHPUnit 11 support.

1.15.0

Included commits: 1.14.0...1.15.0

Improvements

• Adjusted QueueFacade::startWorker() to ignore default timeout if the stop-when-empty option is provided.

1.14.0

Included commits: 1.13.0...1.14.0

Improvements

• Introduced QueueConstants::QUEUE_MESSAGE_CHUNK_SIZE_MAP.
• Introduced QueueConstants::MAX_QUEUE_TASK_MEMORY_CHUNK_SIZE.
• Introduced QueueConstants::MAX_QUEUE_TASK_MEMORY_SIZE.
• Introduced QueueConfig::QUEUE_TASK_MEMORY_USAGE_THRESHOLD.
• Introduced QueueConfig::getQueueMessageChunkSizeMap() to return a map that associates the queue name with the number of messages to be fetched from that queue in a single chunk.
• Introduced QueueConfig::getMaxQueueTaskMemoryChunkSize() to return the recommended (optimal) memory of queue task chunk size for event message processing in KB.
• Introduced QueueConfig::getMaxQueueTaskMemorySize() to return recommended (optimal) memory limit for the entire queue task process in MB.
• Adjusted QueueFacade::startTask() to retrieve the batch size from QueueConfig::getQueueMessageChunkSizeMap() by queue name. Added warning logs when memory usage exceeds limits defined by QueueConfig::getMaxQueueTaskMemoryChunkSize() and QueueConfig::getMaxQueueTaskMemorySize(), with a fallback to processor plugin.
• Adjusted QueueFacade::startTaskWithReport() to retrieve the batch size from QueueConfig::getQueueMessageChunkSizeMap() by queue name. Added warning logs when memory usage exceeds limits defined by QueueConfig::getMaxQueueTaskMemoryChunkSize() and QueueConfig::getMaxQueueTaskMemorySize(), with a fallback to processor plugin.

Adjustments

• Added Log module to dependencies.