public function __construct(
        #[Autowire(service: 'api_platform.doctrine.orm.state.persist_processor')]
        private ProcessorInterface $persistProcessor,
        private UpdateObjectProvider $scheduler
    ) {
    }

public function process(
        mixed $data,
        Operation $operation,
        array $uriVariables = [],
        array $context = []
) {
    $this->persistProcessor->process($data, $operation, $uriVariables, $context);
    $task = new Task();
    $recurringMessage = RecurringMessage::every(
        '10 seconds',
        $task
    );

    $task->messageId = $recurringMessage->getId();
    $this->scheduler->add($recurringMessage);
}  

final class Task
{

    public private(set) Uuid $objectId {
        get {
            return $this->objectId;
        }
    }

    public string $messageId {
        get => $this->messageId;
        set(string $value) => $this->messageId = $value;
    }

    public function __construct(Uuid $objectId)
    {
        $this->objectId = $objectId;
    }
}

#[AsSchedule('object')]
final class UpdateObjectProvider implements ScheduleProviderInterface
{
    private Schedule $schedule;

    public function getSchedule(): Schedule
    {
        return $this->schedule ??= new Schedule();
    }

    public function add(RecurringMessage $message): void
    {
        $this->getSchedule()->add($message);
    }

    public function remove(RecurringMessage $message): void
    {
        $this->getSchedule()->remove($message);
    }
}

#[AsMessageHandler]
final class UpdateObjectTaskHandler
{
    public function __construct(
        private EntityManagerInterface $entityManager,
        private UpdateObjectProvider $scheduler,
    ) {
    }

    public function __invoke(UpdateDiagnosticStateTask $message)
    {
        $object = $this->entityManager->getRepository(Object::class)->findOneBy(
            ['uid' => $message->objectId]
        );

        //logic

        if (/*condition to remove the Message */) {
            $this->scheduler->getSchedule()->removeById($message->messageId);
        }
    }
}