// Path: src/main/java/com/googlesource/gerrit/plugins/replication/ReplicationQueue.java
// static final NamedFluentLogger repLog = NamedFluentLogger.forName(REPLICATION_LOG_NAME);


import static com.google.common.base.Suppliers.memoize;
import static com.googlesource.gerrit.plugins.replication.ReplicationQueue.repLog;
import com.google.common.base.MoreObjects;
import com.google.common.collect.ImmutableList;
import com.google.gerrit.server.config.ConfigUtil;
import java.util.concurrent.TimeUnit;
import java.util.function.Supplier;
import org.eclipse.jgit.lib.Config;
import org.eclipse.jgit.transport.RemoteConfig;
    remoteNameStyle =
        MoreObjects.firstNonNull(cfg.getString("remote", name, "remoteNameStyle"), "slash");
    maxRetries =
        getInt(
            remoteConfig, cfg, "replicationMaxRetries", cfg.getInt("replication", "maxRetries", 0));

    slowLatencyThreshold =
        (int)
            ConfigUtil.getTimeUnit(
                cfg,
                "remote",
                remoteConfig.getName(),
                "slowLatencyThreshold",
                DEFAULT_SLOW_LATENCY_THRESHOLD_SECS,
                TimeUnit.SECONDS);

    pushBatchSize =
        memoize(
            () -> {
              int configuredBatchSize =
                  Math.max(
                      0,
                      getInt(
                          remoteConfig,
                          cfg,
                          "pushBatchSize",
                          cfg.getInt("gerrit", "pushBatchSize", 0)));
              if (configuredBatchSize > 0) {
                int distributionInterval = cfg.getInt("replication", "distributionInterval", 0);
                if (distributionInterval > 0) {
// Path: src/main/java/com/googlesource/gerrit/plugins/replication/ReplicationQueue.java
// static final NamedFluentLogger repLog = NamedFluentLogger.forName(REPLICATION_LOG_NAME);


// Path: src/main/java/com/googlesource/gerrit/plugins/replication/DestinationConfiguration.java
import static com.google.common.base.Suppliers.memoize;
import static com.googlesource.gerrit.plugins.replication.ReplicationQueue.repLog;
import com.google.common.base.MoreObjects;
import com.google.common.collect.ImmutableList;
import com.google.gerrit.server.config.ConfigUtil;
import java.util.concurrent.TimeUnit;
import java.util.function.Supplier;
import org.eclipse.jgit.lib.Config;
import org.eclipse.jgit.transport.RemoteConfig;

    remoteNameStyle =
        MoreObjects.firstNonNull(cfg.getString("remote", name, "remoteNameStyle"), "slash");
    maxRetries =
        getInt(
            remoteConfig, cfg, "replicationMaxRetries", cfg.getInt("replication", "maxRetries", 0));

    slowLatencyThreshold =
        (int)
            ConfigUtil.getTimeUnit(
                cfg,
                "remote",
                remoteConfig.getName(),
                "slowLatencyThreshold",
                DEFAULT_SLOW_LATENCY_THRESHOLD_SECS,
                TimeUnit.SECONDS);

    pushBatchSize =
        memoize(
            () -> {
              int configuredBatchSize =
                  Math.max(
                      0,
                      getInt(
                          remoteConfig,
                          cfg,
                          "pushBatchSize",
                          cfg.getInt("gerrit", "pushBatchSize", 0)));
              if (configuredBatchSize > 0) {
                int distributionInterval = cfg.getInt("replication", "distributionInterval", 0);
                if (distributionInterval > 0) {
                  repLog.atWarning().log(