public void loadPlugin()

in common/src/main/java/org/apache/rocketmq/schema/registry/common/storage/StorageManager.java [61:77]

15 lines of code
4 McCabe index (conditional complexity)


    public void loadPlugin() {
        if (!state.compareAndSet(PluginLoadState.INIT, PluginLoadState.LOADING)) {
            return;
        }

        final ServiceLoader<StoragePlugin> serviceLoader =
            ServiceLoader.load(StoragePlugin.class, this.getClass().getClassLoader());
        for (StoragePlugin storagePlugin : serviceLoader) {
            if (config.getStorageType().equals(storagePlugin.getType())) {
                log.info("Loading plugin {}", storagePlugin.getClass().getName());
                this.plugin = storagePlugin;
                log.info("Finished loading plugin {}", storagePlugin.getClass().getName());
            }
        }

        state.set(PluginLoadState.LOADED);
    }