在信使处理程序中,如果消息的处理时间比心跳时间长,则由于连接断开,您将无法确认消息。
处理程序中有没有办法手动保持连接处于活动状态?将消息发布到“ping”队列是否足够?
例子:
public function __invoke(SampleMessage $message)
{
foreach ($message->listOfSomething() as $something) {
$this->reallyLongRunningTask($something);
$this->messageBus->dispatch(new PingMessage());
}
}
提前致谢