fixed OverflowStrategy in SupervisedStream to backpressure instead of…

… failing Signed-off-by: Thomas Jäckle <thomas.jaeckle@beyonnex.io>
eclipse-ditto · Apr 18, 2023 · ba9b820 · ba9b820
1 parent a0aba9a
commit ba9b820
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...ce/src/main/java/org/eclipse/ditto/gateway/service/streaming/actors/SupervisedStream.java b/...ce/src/main/java/org/eclipse/ditto/gateway/service/streaming/actors/SupervisedStream.java
@@ -35,7 +35,7 @@ public interface SupervisedStream {
      * @return the source queue.
      */
     static Source<SessionedJsonifiable, WithQueue> sourceQueue(final int queueSize) {
-        return Source.<SessionedJsonifiable>queue(queueSize, OverflowStrategy.fail().withLogLevel(Logging.WarningLevel()))
+        return Source.<SessionedJsonifiable>queue(queueSize, OverflowStrategy.backpressure().withLogLevel(Logging.WarningLevel()))
                 .viaMat(KillSwitches.single(), Keep.both())
                 .mapMaterializedValue(pair -> {
                     final SourceQueueWithComplete<SessionedJsonifiable> sourceQueue = pair.first();