2

在信使处理程序中,如果消息的处理时间比心跳时间长,则由于连接断开,您将无法确认消息。

处理程序中有没有办法手动保持连接处于活动状态?将消息发布到“ping”队列是否足够?

例子:

public function __invoke(SampleMessage $message)
{
    foreach ($message->listOfSomething() as $something) {
        $this->reallyLongRunningTask($something);
        $this->messageBus->dispatch(new PingMessage());
    }
}

提前致谢

4

0 回答 0