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 プラグインを有効にしています)