remove noisy INFO log statement in StreamingSessionActor

Signed-off-by: Thomas Jäckle <thomas.jaeckle@beyonnex.io>
eclipse-ditto · Dec 19, 2023 · 9f0138b · 9f0138b
1 parent 28bccd8
commit 9f0138b
Showing 1 changed file with 15 additions and 16 deletions.
diff --git a/...c/main/java/org/eclipse/ditto/gateway/service/streaming/actors/StreamingSessionActor.java b/...c/main/java/org/eclipse/ditto/gateway/service/streaming/actors/StreamingSessionActor.java
@@ -24,6 +24,21 @@
 
 import javax.annotation.Nullable;
 
+import org.apache.pekko.Done;
+import org.apache.pekko.actor.AbstractActorWithTimers;
+import org.apache.pekko.actor.ActorRef;
+import org.apache.pekko.actor.Cancellable;
+import org.apache.pekko.actor.CoordinatedShutdown;
+import org.apache.pekko.actor.Props;
+import org.apache.pekko.actor.Terminated;
+import org.apache.pekko.japi.pf.PFBuilder;
+import org.apache.pekko.japi.pf.ReceiveBuilder;
+import org.apache.pekko.pattern.Patterns;
+import org.apache.pekko.stream.KillSwitch;
+import org.apache.pekko.stream.SourceRef;
+import org.apache.pekko.stream.javadsl.Keep;
+import org.apache.pekko.stream.javadsl.Sink;
+import org.apache.pekko.stream.javadsl.SourceQueueWithComplete;
 import org.eclipse.ditto.base.model.acks.AcknowledgementLabel;
 import org.eclipse.ditto.base.model.acks.AcknowledgementLabelNotDeclaredException;
 import org.eclipse.ditto.base.model.acks.AcknowledgementLabelNotUniqueException;
@@ -87,21 +102,6 @@
 import org.eclipse.ditto.thingsearch.model.signals.commands.ThingSearchCommand;
 import org.eclipse.ditto.thingsearch.model.signals.events.SubscriptionEvent;
 
-import org.apache.pekko.Done;
-import org.apache.pekko.actor.AbstractActorWithTimers;
-import org.apache.pekko.actor.ActorRef;
-import org.apache.pekko.actor.Cancellable;
-import org.apache.pekko.actor.CoordinatedShutdown;
-import org.apache.pekko.actor.Props;
-import org.apache.pekko.actor.Terminated;
-import org.apache.pekko.japi.pf.PFBuilder;
-import org.apache.pekko.japi.pf.ReceiveBuilder;
-import org.apache.pekko.pattern.Patterns;
-import org.apache.pekko.stream.KillSwitch;
-import org.apache.pekko.stream.SourceRef;
-import org.apache.pekko.stream.javadsl.Keep;
-import org.apache.pekko.stream.javadsl.Sink;
-import org.apache.pekko.stream.javadsl.SourceQueueWithComplete;
 import scala.PartialFunction;
 
 /**
@@ -314,7 +314,6 @@ private Receive createOutgoingSignalBehavior() {
                     @Nullable final var session = streamingSessions.get(streamingType);
                     if (null != session && isSessionAllowedToReceiveSignal(signal, session, streamingType)) {
                         final ThreadSafeDittoLoggingAdapter l = logger.withCorrelationId(signal);
-                        l.info("Publishing Signal of type <{}> in <{}> session", signal.getType(), type);
                         l.debug("Publishing Signal of type <{}> in <{}> session: {}", type, signal.getType(), signal);
 
                         final DittoHeaders sessionHeaders = DittoHeaders.newBuilder()