Skip to content

Releases: spryker/queue

1.28.0

Choose a tag to compare

@spryker-release-bot spryker-release-bot released this 28 May 13:46

Included commits: 1.27.1...1.28.0

Fixes

  • Fixed the worker to skip queues not present in the configured queue names list during bulk execution, preventing unintended processing of error queues.

1.27.1

Choose a tag to compare

@spryker-release-bot spryker-release-bot released this 19 May 07:05

Included commits: 1.27.0...1.27.1

Fixes

  • Fixed queue worker logic to skip the stop check when processes just finished, ensuring messages published to downstream queues during adjusted queue logic are visible on the next iteration.

1.27.0

Choose a tag to compare

@spryker-release-bot spryker-release-bot released this 14 May 16:52

Included commits: 1.26.0...1.27.0

Improvements

  • Introduced ProcessManagerInterface::flushZombieProcesses() and ProcessManager::flushZombieProcesses() to detect and remove defunct PHP processes, preventing zombie process accumulation.
  • Added Worker::registerKillSignalHandlers() to gracefully flush all worker processes on SIGTERM, SIGINT, and SIGHUP signals, ensuring clean worker shutdown.
  • Adjusted Worker::start() to flush zombie processes and register kill signal handlers on the first worker round, and to finish the progress bar and flush idle processes when the queue is empty.
  • Fixed ProcessManager::flushAllWorkerProcesses() to send SIGKILL to running processes before deleting their records, ensuring processes are properly terminated.

1.26.0

Choose a tag to compare

@spryker-release-bot spryker-release-bot released this 12 May 12:40

Included commits: 1.25.0...1.26.0

Fixes

  • Fixed Worker::waitForPendingProcesses() to use an iterative loop instead of recursion, preventing stack overflows on large backlogs and correctly continuing to wait as long as pending processes remain.
  • Removed the initial sleep delay before the first worker process is triggered in startProcessesForKnownNonEmptyQueue() and startProcesses() to reduce queue startup latency.

1.25.0

Choose a tag to compare

@spryker-release-bot spryker-release-bot released this 27 Apr 05:39

Included commits: 1.24.0...1.25.0

Improvements

  • Introduced QueueFacade::areQueuesEmpty() to enable checking whether all registered queues have no messages ready for consumption.

1.24.0

Choose a tag to compare

@spryker-release-bot spryker-release-bot released this 01 Apr 15:24

Included commits: 1.23.0...1.24.0

Improvements

  • Added QueueConstants::QUEUE_WORKER_DELAY_WHEN_NOT_EMPTY_MILLISECONDS and QueueConfig::getDelayWhenQueueIsNotEmptyMilliseconds() to configure worker delay for non-empty queue processing in queue worker performance optimization.
  • Added QueueConstants::QUEUE_BULK_MESSAGE_CHECK_ENABLED and QueueConfig::isQueueBulkMessageCheckEnabled() to enable bulk queue state checks in queue worker performance optimization.
  • Adjusted Worker and ResourceAwareQueueWorker execution flow to support bulk queue checks and optimized queue-processing loop/logging behavior.

1.23.0

Choose a tag to compare

@spryker-release-bot spryker-release-bot released this 17 Mar 22:13

Included commits: 1.22.1...1.23.0

Adjustments

  • Added compatibility with Gui module version 5 to support the updated Backoffice theme Inspinia v2.

1.22.1

Choose a tag to compare

@spryker-release-bot spryker-release-bot released this 21 Jan 08:55

Included commits: 1.22.0...1.22.1

Fixes

  • Updated Transfer module constraint to enable compatibility with new transfer features.

1.22.0

Choose a tag to compare

@spryker-release-bot spryker-release-bot released this 28 Nov 13:11

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

Choose a tag to compare

@spryker-release-bot spryker-release-bot released this 19 Nov 14:26

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.