如何使用带有 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 插件)