renamed somma Akka leftovers in javadocs

Signed-off-by: Stanchev Aleksandar <aleksandar.stanchev@bosch.com>

base/model/src/main/java/org/eclipse/ditto/base/model/headers/DittoHeaderDefinition.java

@@ -441,7 +441,7 @@ public enum DittoHeaderDefinition implements HeaderDefinition {
             HeaderValueValidators.getBooleanValidator()),
 
     /**
-     * Internal header passing through the Akka address of an {@code AcknowledgementAggregatorActor} which was started
+     * Internal header passing through the Pekko address of an {@code AcknowledgementAggregatorActor} which was started
      * at an edge (gateway/connectivity) and is awaiting {@code Acknowledgement}s which can be sent to it by using
      * this address in an {@code ActorSelection}.
      *

base/model/src/main/java/org/eclipse/ditto/base/model/headers/JsonFieldSelectorValidator.java

@@ -30,7 +30,7 @@
 final class JsonFieldSelectorValidator extends AbstractHeaderValueValidator {
 
     /**
-     * Don't configure URL decoding as JsonParseOptions because Akka-Http already decodes the fields-param and we would
+     * Don't configure URL decoding as JsonParseOptions because Pekko-Http already decodes the fields-param and we would
      * decode twice.
      */
     private static final JsonParseOptions JSON_FIELD_SELECTOR_PARSE_OPTIONS = JsonFactory.newParseOptionsBuilder()

base/service/src/main/java/org/eclipse/ditto/base/service/DittoService.java

@@ -255,9 +255,9 @@ private void startPrometheusReporter() {
     }
 
     /**
-     * Starts the Akka actor system as well as all required actors.
+     * Starts the Pekko actor system as well as all required actors.
      * <p>
-     * May be overridden to change the way how the Akka actor system and actors are started. <em>Note: If this method is
+     * May be overridden to change the way how the Pekko actor system and actors are started. <em>Note: If this method is
      * overridden, none of the following mentioned methods and their descendant methods will be called
      * automatically:</em>
      * </p>
@@ -267,7 +267,7 @@ private void startPrometheusReporter() {
      * <li>{@link #startServiceRootActors(ActorSystem, org.eclipse.ditto.base.service.config.ServiceSpecificConfig)}.</li>
      * </ul>
      *
-     * @param actorSystem the Akka ActorSystem to be initialized.
+     * @param actorSystem the Pekko ActorSystem to be initialized.
      */
     private void initializeActorSystem(final ActorSystem actorSystem) {
         startPekkoManagement(actorSystem);
@@ -310,7 +310,7 @@ private void startKamonPrometheusHttpEndpoint(final ActorSystem actorSystem) {
     }
 
     /**
-     * Creates the Akka actor system. May be overridden to change the way how the actor system is created.
+     * Creates the Pekko actor system. May be overridden to change the way how the actor system is created.
      *
      * @param config the configuration settings of this service.
      * @return the actor system.
@@ -342,7 +342,7 @@ private void startClusterBootstrap(final ActorSystem actorSystem) {
      * Starts the {@link org.eclipse.ditto.internal.utils.health.status.StatusSupplierActor}.
      * May be overridden to change the way how the actor is started.
      *
-     * @param actorSystem Akka actor system for starting actors.
+     * @param actorSystem Pekko actor system for starting actors.
      */
     private void startStatusSupplierActor(final ActorSystem actorSystem) {
         startActor(actorSystem, StatusSupplierActor.props(rootActorName), StatusSupplierActor.ACTOR_NAME);
@@ -361,7 +361,7 @@ private void logStartingActor(final String actorName) {
      * Starts the {@link org.eclipse.ditto.base.service.devops.DevOpsCommandsActor}.
      * May be overridden to change the way how the actor is started.
      *
-     * @param actorSystem Akka actor system for starting actors.
+     * @param actorSystem Pekko actor system for starting actors.
      */
     private void startDevOpsCommandsActor(final ActorSystem actorSystem) {
         startActor(actorSystem, DevOpsCommandsActor.props(LogbackLoggingFacade.newInstance(), serviceName,
@@ -379,7 +379,7 @@ private void startDevOpsCommandsActor(final ActorSystem actorSystem) {
      * <li>{@link #startMainRootActor(org.apache.pekko.actor.ActorSystem, org.apache.pekko.actor.Props)},</li>
      * </ul>
      *
-     * @param actorSystem Akka actor system for starting actors.
+     * @param actorSystem Pekko actor system for starting actors.
      * @param serviceSpecificConfig the configuration settings of this service.
      */
     private void startServiceRootActors(final ActorSystem actorSystem, final C serviceSpecificConfig) {
@@ -437,7 +437,7 @@ private static ActorRef getDistributedPubSubMediatorActor(final ActorSystem acto
      * Starts the main root actor of this service. May be overridden to change the way of starting this service's root
      * actor.
      *
-     * @param actorSystem Akka actor system for starting actors.
+     * @param actorSystem Pekko actor system for starting actors.
      * @param mainRootActorProps the Props of the main root actor.
      */
     private ActorRef startMainRootActor(final ActorSystem actorSystem, final Props mainRootActorProps) {

base/service/src/main/java/org/eclipse/ditto/base/service/DockerSwarmServiceDiscovery.java

@@ -35,7 +35,7 @@
  * <p>
  * One speciality of a Docker swarm based cluster is that the Docker swarm DNS sets a TTL of DNS entries to 600 seconds
  * (10 minutes) - so if a cluster forms and not all DNS entries are "there" from the beginning, it takes 10 minutes
- * until DNS caches used by the default Akka {@link org.apache.pekko.discovery.dns.DnsServiceDiscovery DnsServiceDiscovery} are
+ * until DNS caches used by the default Pekko {@link org.apache.pekko.discovery.dns.DnsServiceDiscovery DnsServiceDiscovery} are
  * evicted and another DNS lookup is done.
  * </p>
  * This implementation does not cache DNS entries and can therefore be used for bootstrapping in Docker swarm.

base/service/src/main/java/org/eclipse/ditto/base/service/actors/ShutdownBehaviour.java

@@ -48,7 +48,7 @@ private ShutdownBehaviour(final String namespace, final EntityId entityId, final
      * Create the actor behavior from its entity ID and reference.
      *
      * @param entityId entity ID to react to.
-     * @param pubSubMediator Akka pub-sub mediator.
+     * @param pubSubMediator Pekko pub-sub mediator.
      * @param self reference of the actor itself.
      * @return the actor behavior.
      */
@@ -64,7 +64,7 @@ public static ShutdownBehaviour fromId(final NamespacedEntityId entityId,
      * Create the actor behavior from its entity ID (without namespace) and reference.
      *
      * @param entityId entity ID to react to.
-     * @param pubSubMediator Akka pub-sub mediator.
+     * @param pubSubMediator Pekko pub-sub mediator.
      * @param self reference of the actor itself.
      * @return the actor behavior.
      */
@@ -79,7 +79,7 @@ public static ShutdownBehaviour fromIdWithoutNamespace(final EntityId entityId,
      * Create the actor behavior from a namespace and ID.
      *
      * @param entityId the entity ID.
-     * @param pubSubMediator Akka pub-sub mediator.
+     * @param pubSubMediator Pekko pub-sub mediator.
      * @param self reference of the actor itself.
      * @param namespace the namespace of the actor.
      * @return the actor behavior.

base/service/src/main/java/org/eclipse/ditto/base/service/cluster/DittoSplitBrainResolver.java

@@ -83,10 +83,10 @@ private void updateEnabled(final ModifySplitBrainResolver modifySplitBrainResolv
             autoEnabling.cancel();
         }
         if (modifySplitBrainResolver.isEnabled() && splitBrainResolverActor == null) {
-            LOGGER.info("Enabling Akka split brain resolver");
+            LOGGER.info("Enabling Pekko split brain resolver");
             splitBrainResolverActor = startChildActor(splitBrainResolverProps);
         } else if (!modifySplitBrainResolver.isEnabled() && splitBrainResolverActor != null) {
-            LOGGER.info("Stopping Akka split brain resolver");
+            LOGGER.info("Stopping Pekko split brain resolver");
             getContext().stop(splitBrainResolverActor);
             splitBrainResolverActor = null;
         }

base/service/src/main/java/org/eclipse/ditto/base/service/config/http/HttpProxyConfig.java

@@ -60,10 +60,10 @@ public interface HttpProxyConfig {
     String getPassword();
 
     /**
-     * Converts the proxy settings to an Akka HTTP client transport object.
+     * Converts the proxy settings to an Pekko HTTP client transport object.
      * Does not check whether the proxy is enabled.
      *
-     * @return an Akka HTTP client transport object matching this config.
+     * @return an Pekko HTTP client transport object matching this config.
      */
     ClientTransport toClientTransport();
 

base/service/src/main/java/org/eclipse/ditto/base/service/devops/DevOpsCommandsActor.java

@@ -125,12 +125,12 @@ private DevOpsCommandsActor(final LoggingFacade loggingFacade, final String serv
     }
 
     /**
-     * Creates Akka configuration object Props for this Actor.
+     * Creates Pekko configuration object Props for this Actor.
      *
      * @param loggingFacade a facade providing logging functionality.
      * @param serviceName name of the microservice.
      * @param instance instance number of the microservice instance.
-     * @return the Akka configuration Props object.
+     * @return the Pekko configuration Props object.
      */
     public static Props props(final LoggingFacade loggingFacade, final String serviceName, final String instance) {
         return Props.create(DevOpsCommandsActor.class, loggingFacade, serviceName, instance);
@@ -442,7 +442,7 @@ private PubSubSubscriberActor(final ActorRef pubSubMediator, final String servic
         }
 
         /**
-         * @return the Akka configuration Props object.
+         * @return the Pekko configuration Props object.
          */
         static Props props(final ActorRef pubSubMediator,
                 final String serviceName,
@@ -536,7 +536,7 @@ private static boolean isAggregateResults(final DittoHeaders dittoHeaders) {
         }
 
         /**
-         * @return the Akka configuration Props object.
+         * @return the Pekko configuration Props object.
          */
         static Props props(final ActorRef devOpsCommandSender, final DevOpsCommand<?> devOpsCommand,
                 final int expectedResponses) {

connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/ConnectivityRootActor.java

@@ -128,11 +128,11 @@ private ConnectivityRootActor(final ConnectivityConfig connectivityConfig,
     }
 
     /**
-     * Creates Akka configuration object Props for this ConnectivityRootActor.
+     * Creates Pekko configuration object Props for this ConnectivityRootActor.
      *
      * @param connectivityConfig the configuration of the Connectivity service.
      * @param pubSubMediator the PubSub mediator Actor.
-     * @return the Akka configuration Props object.
+     * @return the Pekko configuration Props object.
      */
     public static Props props(final ConnectivityConfig connectivityConfig, final ActorRef pubSubMediator) {
 

connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/ConnectivityService.java

@@ -30,7 +30,7 @@
  * Entry point of the Connectivity service.
  * <ul>
  *     <li>Reads configuration, enhances it with cloud environment settings.</li>
- *     <li>Sets up Akka actor system.</li>
+ *     <li>Sets up Pekko actor system.</li>
  * </ul>
  */
 @AllParametersAndReturnValuesAreNonnullByDefault
@@ -39,7 +39,7 @@ public final class ConnectivityService extends DittoService<ConnectivityConfig>
     private static final Logger LOGGER = LoggerFactory.getLogger(ConnectivityService.class);
 
     /**
-     * Name for the Akka Actor System of the Connectivity service.
+     * Name for the Pekko Actor System of the Connectivity service.
      */
     public static final String SERVICE_NAME = "connectivity";
 

connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/BaseClientActor.java

@@ -294,7 +294,7 @@ public void preStart() throws Exception {
         // volatile states
         //
         // DO NOT use state timeout:
-        // FSM state timeout gets reset by any message, AND cannot be longer than 5 minutes (Akka v2.5.23).
+        // FSM state timeout gets reset by any message, AND cannot be longer than 5 minutes (Pekko v2.5.23).
         when(DISCONNECTING, inDisconnectingState());
         when(CONNECTING, inConnectingState());
         when(TESTING, inTestingState());

connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/ConnectionIdsRetrievalActor.java

@@ -98,11 +98,11 @@ public void preStart() {
     }
 
     /**
-     * Creates Akka configuration object Props for this Actor.
+     * Creates Pekko configuration object Props for this Actor.
      *
      * @param readJournal readJournal to extract current PIDs from.
      * @param connectionIdsRetrievalConfig the config to build the pid suppliers from.
-     * @return the Akka configuration Props object.
+     * @return the Pekko configuration Props object.
      */
     public static Props props(final MongoReadJournal readJournal,
             final ConnectionIdsRetrievalConfig connectionIdsRetrievalConfig) {

connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/OutboundMappingProcessorActor.java

@@ -269,15 +269,15 @@ private int determinePoolSize(final int connectionPoolSize, final int maxPoolSiz
     }
 
     /**
-     * Creates Akka configuration object for this actor.
+     * Creates Pekko configuration object for this actor.
      *
      * @param clientActor the client actor that created this mapping actor.
      * @param outboundMappingProcessors the MessageMappingProcessors to use for outbound messages. If at least as many
      * processors are given as `processorPoolSize`, then each processor is guaranteed to be invoked sequentially.
      * @param connection the connection.
      * @param connectivityConfig the config of the connectivity service with potential overwrites.
      * @param processorPoolSize how many message processing may happen in parallel per direction (incoming or outgoing).
-     * @return the Akka configuration Props object.
+     * @return the Pekko configuration Props object.
      */
     public static Props props(final ActorRef clientActor,
             final List<OutboundMappingProcessor> outboundMappingProcessors,

connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/amqp/AmqpClientActor.java

@@ -168,16 +168,16 @@ private AmqpClientActor(final Connection connection,
     }
 
     /**
-     * Creates Akka configuration object for this actor.
+     * Creates Pekko configuration object for this actor.
      *
      * @param connection the connection.
      * @param commandForwarderActor the actor used to send signals into the ditto cluster.
      * @param connectionActor the connectionPersistenceActor which created this client.
      * @param configOverwrites an override for the default connectivity config values -
      * @param actorSystem the actor system.
-     * as Typesafe {@code Config} because this one is serializable in Akka by default.
+     * as Typesafe {@code Config} because this one is serializable in Pekko by default.
      * @param dittoHeaders headers of the command that caused this actor to be created.
-     * @return the Akka configuration Props object.
+     * @return the Pekko configuration Props object.
      */
     public static Props props(final Connection connection, final ActorRef commandForwarderActor,
             final ActorRef connectionActor, final Config configOverwrites, final ActorSystem actorSystem,
@@ -187,14 +187,14 @@ public static Props props(final Connection connection, final ActorRef commandFor
     }
 
     /**
-     * Creates Akka configuration object for this actor.
+     * Creates Pekko configuration object for this actor.
      *
      * @param connection connection parameters.
      * @param commandForwarderActor the actor used to send signals into the ditto cluster.
      * @param connectionActor the connectionPersistenceActor which created this client.
      * @param jmsConnectionFactory the JMS connection factory.
      * @param actorSystem the actor system.
-     * @return the Akka configuration Props object.
+     * @return the Pekko configuration Props object.
      */
     static Props propsForTest(final Connection connection, @Nullable final ActorRef commandForwarderActor,
             final ActorRef connectionActor, final JmsConnectionFactory jmsConnectionFactory,

connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/amqp/AmqpConsumerActor.java

@@ -134,7 +134,7 @@ private AmqpConsumerActor(final Connection connection, final ConsumerData consum
     }
 
     /**
-     * Creates Akka configuration object {@link Props} for this {@code AmqpConsumerActor}.
+     * Creates Pekko configuration object {@link Props} for this {@code AmqpConsumerActor}.
      *
      * @param connection the connection
      * @param consumerData the consumer data.
@@ -143,7 +143,7 @@ private AmqpConsumerActor(final Connection connection, final ConsumerData consum
      * @param connectivityStatusResolver connectivity status resolver to resolve occurred exceptions to a connectivity
      * status.
      * @param connectivityConfig the connectivity config related to the given connection.
-     * @return the Akka configuration Props object.
+     * @return the Pekko configuration Props object.
      */
     static Props props(final Connection connection, final ConsumerData consumerData,
             final Sink<Object, ?> inboundMappingSink, final ActorRef jmsActor,

connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/amqp/AmqpPublisherActor.java

@@ -169,14 +169,14 @@ private static CompletableFuture<Object> triggerPublishAsync(
     }
 
     /**
-     * Creates Akka configuration object {@link Props} for this {@code AmqpPublisherActor}.
+     * Creates Pekko configuration object {@link Props} for this {@code AmqpPublisherActor}.
      *
      * @param connection the connection this publisher belongs to
      * @param session the jms session
      * @param connectivityStatusResolver connectivity status resolver to resolve occurred exceptions to a connectivity
      * status.
      * @param connectivityConfig the connectivity configuration including potential overwrites.
-     * @return the Akka configuration Props object.
+     * @return the Pekko configuration Props object.
      */
     static Props props(final Connection connection,
             final Session session,

connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/amqp/JMSConnectionHandlingActor.java

@@ -103,13 +103,13 @@ private JMSConnectionHandlingActor(final Connection connection,
     }
 
     /**
-     * Creates Akka configuration object {@link Props} for this {@code JMSConnectionHandlingActor}.
+     * Creates Pekko configuration object {@link Props} for this {@code JMSConnectionHandlingActor}.
      *
      * @param connection the connection
      * @param exceptionListener the exception listener
      * @param jmsConnectionFactory the jms connection factory
      * @param connectionLogger used to log failures during certificate validation.
-     * @return the Akka configuration Props object.
+     * @return the Pekko configuration Props object.
      */
     static Props props(final Connection connection, final ExceptionListener exceptionListener,
             final JmsConnectionFactory jmsConnectionFactory, final ConnectionLogger connectionLogger) {

connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/DefaultHttpPushFactory.java

@@ -251,7 +251,7 @@ private static ConnectionPoolSettings disambiguateByConnectionId(final ActorSyst
 
         final ParserSettings parserSettings = ParserSettings.forClient(system);
 
-        // start with the default maximum cached value per header of Akka HTTP.
+        // start with the default maximum cached value per header of Pekko HTTP.
         // "default=12" should be kept consistent with akka-http reference.conf
         final Map<String, Object> disambiguator = new HashMap<>(parserSettings.getHeaderValueCacheLimits());
         disambiguator.put(id.toString(), disambiguator.getOrDefault("default", 12));

connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/HttpPublishTarget.java

@@ -40,7 +40,7 @@ private HttpPublishTarget(final HttpMethod method, final String pathWithQuery) {
     }
 
     /**
-     * @return the Akka HTTP method to use for the HTTP request.
+     * @return the Pekko HTTP method to use for the HTTP request.
      */
     HttpMethod getMethod() {
         return method;

connectivity/service/src/main/java/org/eclipse/ditto/connectivity/service/messaging/httppush/HttpPublisherActor.java

@@ -168,14 +168,14 @@ private HttpPublisherActor(final Connection connection,
     }
 
     /**
-     * Creates Akka configuration object for this actor.
+     * Creates Pekko configuration object for this actor.
      *
      * @param connection the connection.
      * @param factory the http push factory to use.
      * @param connectivityStatusResolver connectivity status resolver to resolve occurred exceptions to a connectivity
      * status.
      * @param connectivityConfig the config of the connectivity service with potential overwrites.
-     * @return the Akka configuration Props object.
+     * @return the Pekko configuration Props object.
      */
     static Props props(final Connection connection,
             final HttpPushFactory factory,