From c9ab376cfb9b3a84fb925ff3a910ee157f8ceef4 Mon Sep 17 00:00:00 2001 From: Stefan Maute Date: Fri, 23 Sep 2022 11:25:00 +0200 Subject: [PATCH] remove HealthSignal from BaseClientActor because it isn't needed anymore; Signed-off-by: Stefan Maute --- .../service/messaging/BaseClientActor.java | 10 ---------- 1 file changed, 10 deletions(-) diff --git a/connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/BaseClientActor.java b/connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/BaseClientActor.java index 7a225d3465..6fa0de577f 100644 --- a/connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/BaseClientActor.java +++ b/connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/BaseClientActor.java @@ -115,7 +115,6 @@ import org.eclipse.ditto.internal.models.signal.correlation.MatchingValidationResult; import org.eclipse.ditto.internal.utils.akka.logging.DittoLoggerFactory; import org.eclipse.ditto.internal.utils.akka.logging.ThreadSafeDittoLoggingAdapter; -import org.eclipse.ditto.internal.utils.cluster.AkkaJacksonCborSerializable; import org.eclipse.ditto.internal.utils.config.InstanceIdentifierSupplier; import org.eclipse.ditto.internal.utils.config.ScopedConfig; import org.eclipse.ditto.internal.utils.metrics.DittoMetrics; @@ -489,10 +488,6 @@ protected FSMStateFunctionBuilder inAnyState() .event(PublishMappedMessage.class, this::publishMappedMessage) .event(ConnectivityCommand.class, this::onUnknownEvent) // relevant connectivity commands were handled .event(Signal.class, this::handleSignal) - .eventEquals(HealthSignal.PING, (ping, data) -> { - sender().tell(HealthSignal.PONG, self()); - return stay(); - }) .event(FatalPubSubException.class, this::failConnectionDueToPubSubException); } @@ -2253,9 +2248,4 @@ private CloseConnectionAndShutdown() { } } - public enum HealthSignal implements AkkaJacksonCborSerializable { - PING, - PONG - } - }