continue;
} if ($command instanceof InsertCommand
) { $inserts->
addInsert($definition->
getEntityName(),
$command->
getPayload());
continue;
} throw new UnsupportedCommandTypeException($command);
} catch (\Exception
$e) { $command->
setFailed(true
);
$innerException =
$this->exceptionHandlerRegistry->
matchException($e);
if ($innerException instanceof \Exception
) { $e =
$innerException;
} $context->
getExceptions()->
add($e);
throw $e;
}