Если с сообщением что-то пошло не так
$channel->basic_ack($message->delivery_info['delivery_tag']);, то может этого не достаточно? Может надо как-то ещё обозначить завершение импорта для rabbit?
$this->handler->handle($command);public function handle(Command $command)
{
$trades = Trade::create(
$command->uuid,
$command->userId, $command->companyId, $command->categoryId, ....
);
$this->repository->add($trades);
$this->flusher->flush();
}
Ошибка решается передачей правильного параметра, о чём и говорится в предупреждении.