eclipse-ditto#605: Fix test

Signed-off-by: Vadim Guenther <vadim.guenther@bosch.io>
bosch-io · Feb 18, 2021 · d5442c4 · d5442c4
1 parent 839a03e
commit d5442c4
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/.../src/main/java/org/eclipse/ditto/services/connectivity/config/DefaultReconnectConfig.java b/.../src/main/java/org/eclipse/ditto/services/connectivity/config/DefaultReconnectConfig.java
@@ -95,12 +95,13 @@ public boolean equals(final Object o) {
         return Objects.equals(initialDelay, that.initialDelay) &&
                 Objects.equals(interval, that.interval) &&
                 readJournalBatchSize == that.readJournalBatchSize &&
+                readSnapBatchSize == that.readSnapBatchSize &&
                 Objects.equals(rateConfig, that.rateConfig);
     }
 
     @Override
     public int hashCode() {
-        return Objects.hash(initialDelay, interval, readJournalBatchSize, rateConfig);
+        return Objects.hash(initialDelay, interval, readJournalBatchSize, readSnapBatchSize, rateConfig);
     }
 
     @Override
@@ -109,6 +110,7 @@ public String toString() {
                 "initialDelay=" + initialDelay +
                 ", interval=" + interval +
                 ", readJournalBatchSize=" + readJournalBatchSize +
+                ", readSnapBatchSize=" + readSnapBatchSize +
                 ", rateConfig=" + rateConfig +
                 "]";
     }