public void init()

in core/src/main/java/org/apache/ignite/activestore/impl/publisher/Commander.java [95:118]

• 21 lines of code
• 3 McCabe index (conditional complexity)

    public void init() {
        ignite.addCacheConfiguration(AtomicsHelper.getConfig());
        replicasMetadatas = replicaService.getReplicaMetadatasRef(true);
        replicasMetadatas.initIfAbsent(new HashMap<UUID, ReplicaMetadata>());
        main = getReference(ignite, MAIN_ID_ATOMIC_NAME, true);
        main.set(null);

        endpoint = EndpointUtils.publish(address, ActiveCacheStoreService.NAME, mainInterfaceProvider.get());

        String mainSocket = getRpcService(superClusterAddress)
            .get(SuperCluster.class, SuperCluster.NAME)
            .getMain(address);
        boolean isMain = address.equals(mainSocket);
        AtomicsHelper.<ClusterMode>getReference(ignite, MODE_ATOMIC_NAME, true)
            .set(isMain ? ClusterMode.MAIN : ClusterMode.DR);

        if (isMain) {
            processReplicaRegistration(clusterId, dataRecoveryConfig.getReplicaConfig(address), true);
        } else {
            getRpcService(mainSocket)
                .get(ActiveCacheStoreService.class, ActiveCacheStoreService.NAME)
                .register(clusterId, dataRecoveryConfig.getReplicaConfig(address));
        }
    }