Skip to content

Commit

Permalink
remove HealthSignal from BaseClientActor because it isn't needed anym…
Browse files Browse the repository at this point in the history
…ore;

Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
  • Loading branch information
Stefan Maute committed Sep 23, 2022
1 parent 8ee6de9 commit c9ab376
Showing 1 changed file with 0 additions and 10 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down Expand Up @@ -489,10 +488,6 @@ protected FSMStateFunctionBuilder<BaseClientState, BaseClientData> 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);
}

Expand Down Expand Up @@ -2253,9 +2248,4 @@ private CloseConnectionAndShutdown() {
}
}

public enum HealthSignal implements AkkaJacksonCborSerializable {
PING,
PONG
}

}

0 comments on commit c9ab376

Please sign in to comment.