switch to getNonNegativeDurationOrThrow for writeInterval in DefaultS…

…treamConfig; Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
eclipse-ditto · Jul 6, 2021 · a8ef5bd · a8ef5bd
1 parent 8b8a227
commit a8ef5bd
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...rc/main/java/org/eclipse/ditto/thingsearch/service/common/config/DefaultStreamConfig.java b/...rc/main/java/org/eclipse/ditto/thingsearch/service/common/config/DefaultStreamConfig.java
@@ -39,7 +39,7 @@ public final class DefaultStreamConfig implements StreamConfig {
 
     private DefaultStreamConfig(final ConfigWithFallback streamScopedConfig) {
         maxArraySize = streamScopedConfig.getNonNegativeIntOrThrow(StreamConfigValue.MAX_ARRAY_SIZE);
-        writeInterval = streamScopedConfig.getNonNegativeAndNonZeroDurationOrThrow(StreamConfigValue.WRITE_INTERVAL);
+        writeInterval = streamScopedConfig.getNonNegativeDurationOrThrow(StreamConfigValue.WRITE_INTERVAL);
         askTimeout = streamScopedConfig.getNonNegativeDurationOrThrow(StreamConfigValue.ASK_TIMEOUT);
         retrievalConfig = DefaultStreamStageConfig.getInstance(streamScopedConfig, RETRIEVAL_CONFIG_PATH);
         persistenceStreamConfig = DefaultPersistenceStreamConfig.of(streamScopedConfig);