softkultur/magento2-delayed-queue-messages

Allows publishing queue messages with a delay

Maintainers

Package info

github.com/SoftKultur/magento2-delayed-queue-messages

Type:magento2-module

pkg:composer/softkultur/magento2-delayed-queue-messages

Statistics

Installs: 16

Dependents: 0

Suggesters: 0

Stars: 1

Open Issues: 0

Security

Advisories: 0

Aikido package health analysis

1.0.0 2026-03-12 12:37 UTC

Requires

  • php: ^8.1
  • magento/framework: ~103.0.6
  • magento/framework-message-queue: ~100.4.6
  • psr/log: ^2 || ^3

Requires (Dev)

MIT 53295f890c7e775e2dcadd8a33f4e28443065b06

magento 2magento 2 queuesoftkultur

This package is auto-updated.

Last update: 2026-03-12 12:40:25 UTC

README

This Magento2 module allows publishing queue messages to be processed after a specified number of minutes

Installation

Run composer require softKultur/magento2-delayed-queue-messages/ and then bin/magento setup:upgrade.

Technical details

The module introduces a plugin for the \Magento\Framework\MessageQueue\PublisherInterface which checks if the published message is an instance of the \SoftKultur\DelayedQueueMessages\Api\DelayedQueueMessageInterface interface.

The module provides a base implementation for the \SoftKultur\DelayedQueueMessages\Api\DelayedQueueMessageInterface interface which can be used for all types of queue messages payloads: \SoftKultur\DelayedQueueMessages\Model\DelayedQueueMessage

In this case, it saves the message in the softkultur_delayed_queue_message database table.

Each minute, a cronjob checks the said table for unpublished messages that are available (available_at in the past) and publishes them to the corresponding queue.

The module also introduces a new CLI command which runs the same logic as the cronjob: bin/magento softkultur:delayed-queue-messages:publish.