0

rabbit-mq transport で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