From a8ef5bd5cb265399ef929f769fdc56bfd0590db7 Mon Sep 17 00:00:00 2001 From: Stefan Maute Date: Tue, 6 Jul 2021 10:05:46 +0200 Subject: [PATCH] switch to getNonNegativeDurationOrThrow for writeInterval in DefaultStreamConfig; Signed-off-by: Stefan Maute --- .../thingsearch/service/common/config/DefaultStreamConfig.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/thingsearch/service/src/main/java/org/eclipse/ditto/thingsearch/service/common/config/DefaultStreamConfig.java b/thingsearch/service/src/main/java/org/eclipse/ditto/thingsearch/service/common/config/DefaultStreamConfig.java index e8c3c84ce2..80def5949c 100644 --- a/thingsearch/service/src/main/java/org/eclipse/ditto/thingsearch/service/common/config/DefaultStreamConfig.java +++ b/thingsearch/service/src/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);