0

如何使用带有 rabbit-mq 传输的enqueue-bundle延迟消息?我试过这样:

class HelloWorldProcessor implements Processor, CommandSubscriberInterface
{

    public function process(Message $message, Context $context)
    {
        // ... other code
        $message->setHeader('x-delay', 6000);

        return self::REQUEUE;
    }
}

但是没有应用延迟。(我启用了 rabbitmq_delayed_message_exchange 插件)

4

0 回答 0