Mono<Void> resumeExtension() {
        if (!started || running) {
            return Mono.empty();
        }
        return taskScheduler.schedule(Mono.defer(this::resume)
                .doOnSuccess(signalType -> {
                    running = true;
                    LOGGER.info("The extension ({}) of the plugin ({}) has been resumed",
                            getClass().getName(),
                            plugin.descriptor()
                                    .getId());
                }));
    }
The method should be protected, but it is public for testing purposes.
turms-server-common/src/main/java/im/turms/server/common/infra/plugin/TurmsExtension.java