From 9f0138b2077b1cbe5a2acde2a88c798029bbe7c7 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Thomas=20J=C3=A4ckle?= Date: Tue, 19 Dec 2023 15:35:16 +0100 Subject: [PATCH] remove noisy INFO log statement in StreamingSessionActor MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Signed-off-by: Thomas Jäckle --- .../actors/StreamingSessionActor.java | 31 +++++++++---------- 1 file changed, 15 insertions(+), 16 deletions(-) diff --git a/gateway/service/src/main/java/org/eclipse/ditto/gateway/service/streaming/actors/StreamingSessionActor.java b/gateway/service/src/main/java/org/eclipse/ditto/gateway/service/streaming/actors/StreamingSessionActor.java index 942f470f78..7e9c307366 100755 --- a/gateway/service/src/main/java/org/eclipse/ditto/gateway/service/streaming/actors/StreamingSessionActor.java +++ b/gateway/service/src/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()