class ConnectionPersistenceActor extends AbstractShardedPersistenceActor<ConnectivityCommand, Connection, ConnectionId, ConnectionState,
        ConnectivityEvent> {

    public static Props props(final ConnectionId connectionId,
            final DittoProtocolSub dittoProtocolSub,
            final ActorRef proxyActor,
            final ClientActorPropsFactory propsFactory,
            @Nullable final ConnectivityCommandInterceptor commandValidator
    ) {
        return Props.create(ConnectionPersistenceActor.class, connectionId, dittoProtocolSub, proxyActor,
                propsFactory, commandValidator, CLIENT_ACTORS_PER_NODE);
    }

      ConnectionPersistenceActor(final ConnectionId connectionId,
            final DittoProtocolSub dittoProtocolSub,
            final ActorRef proxyActor,
            final ClientActorPropsFactory propsFactory,
            @Nullable final ConnectivityCommandInterceptor customCommandValidator,
            final int clientActorsPerNode);

}