review: renamed consumerRestartBackOffConfig to restartBackOffConfig

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
eclipse-ditto · Sep 7, 2021 · 2e09be3 · 2e09be3
1 parent 27fedfb
commit 2e09be3
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 9 deletions.
diff --git a/...c/main/java/org/eclipse/ditto/connectivity/service/config/DefaultKafkaConsumerConfig.java b/...c/main/java/org/eclipse/ditto/connectivity/service/config/DefaultKafkaConsumerConfig.java
@@ -33,12 +33,12 @@ final class DefaultKafkaConsumerConfig implements KafkaConsumerConfig {
     private static final String RESTART_PATH = "restart";
 
     private final ConnectionThrottlingConfig throttlingConfig;
-    private final ExponentialBackOffConfig consumerRestartBackOffConfig;
+    private final ExponentialBackOffConfig restartBackOffConfig;
     private final Config alpakkaConfig;
 
     private DefaultKafkaConsumerConfig(final Config kafkaConsumerScopedConfig) {
         throttlingConfig = ConnectionThrottlingConfig.of(kafkaConsumerScopedConfig);
-        consumerRestartBackOffConfig =
+        restartBackOffConfig =
                 DefaultExponentialBackOffConfig.of(getConfigOrEmpty(kafkaConsumerScopedConfig, RESTART_PATH));
         alpakkaConfig = getConfigOrEmpty(kafkaConsumerScopedConfig, ALPAKKA_PATH);
     }
@@ -64,8 +64,8 @@ public ConnectionThrottlingConfig getThrottlingConfig() {
     }
 
     @Override
-    public ExponentialBackOffConfig getConsumerRestartBackOffConfig() {
-        return consumerRestartBackOffConfig;
+    public ExponentialBackOffConfig getRestartBackOffConfig() {
+        return restartBackOffConfig;
     }
 
     @Override
@@ -83,20 +83,20 @@ public boolean equals(final Object o) {
         }
         final DefaultKafkaConsumerConfig that = (DefaultKafkaConsumerConfig) o;
         return Objects.equals(throttlingConfig, that.throttlingConfig) &&
-                Objects.equals(consumerRestartBackOffConfig, that.consumerRestartBackOffConfig) &&
+                Objects.equals(restartBackOffConfig, that.restartBackOffConfig) &&
                 Objects.equals(alpakkaConfig, that.alpakkaConfig);
     }
 
     @Override
     public int hashCode() {
-        return Objects.hash(throttlingConfig, consumerRestartBackOffConfig, alpakkaConfig);
+        return Objects.hash(throttlingConfig, restartBackOffConfig, alpakkaConfig);
     }
 
     @Override
     public String toString() {
         return getClass().getSimpleName() + " [" +
                 "throttlingConfig=" + throttlingConfig +
-                ", consumerRestartBackOffConfig=" + consumerRestartBackOffConfig +
+                ", restartBackOffConfig=" + restartBackOffConfig +
                 ", alpakkaConfig=" + alpakkaConfig +
                 "]";
     }

diff --git a/...vice/src/main/java/org/eclipse/ditto/connectivity/service/config/KafkaConsumerConfig.java b/...vice/src/main/java/org/eclipse/ditto/connectivity/service/config/KafkaConsumerConfig.java
@@ -37,7 +37,7 @@ public interface KafkaConsumerConfig {
      *
      * @return the config.
      */
-    ExponentialBackOffConfig getConsumerRestartBackOffConfig();
+    ExponentialBackOffConfig getRestartBackOffConfig();
 
     /**
      * Returns the Config for consumers needed by the Kafka client.

diff --git a/...rc/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaClientActor.java b/...rc/main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaClientActor.java
@@ -230,7 +230,7 @@ private Stream<ConsumerData> consumerDataFromSource(final Source source) {
     private void startKafkaConsumer(final ConsumerData consumerData, final boolean dryRun) {
         final KafkaConsumerConfig consumerConfig = kafkaConfig.getConsumerConfig();
         final ConnectionThrottlingConfig throttlingConfig = consumerConfig.getThrottlingConfig();
-        final ExponentialBackOffConfig consumerRestartBackOffConfig = consumerConfig.getConsumerRestartBackOffConfig();
+        final ExponentialBackOffConfig consumerRestartBackOffConfig = consumerConfig.getRestartBackOffConfig();
         final KafkaConsumerStreamFactory streamFactory =
                 new KafkaConsumerStreamFactory(throttlingConfig, propertiesFactory, consumerData, dryRun);
         final Props consumerActorProps =