This is an automated email from the ASF dual-hosted git repository. He-Pin pushed a commit to branch fix/typos-in-code-and-docs in repository https://gitbox.apache.org/repos/asf/pekko.git
commit e7cfe0219aa92735af0f3f10a634e64c37b5aacb Author: He-Pin <[email protected]> AuthorDate: Thu Jun 11 02:42:51 2026 +0800 fix: correct typos in comments, docs, and string literals across codebase Motivation: Multiple duplicated words ('the the', 'be be', 'with with', 'for for', etc.) and a misspelling ('propagagate') scattered across source code comments, documentation, and log message strings. Modification: - Remove duplicated words in comments, scaladoc, and string literals across 43 files (54 occurrences total) - Fix 'propagagate' → 'propagate' in GraphUnzipWithSpec test name - Fix 'to to' → 'to do' in ShardCoordinator scaladoc Result: Cleaner documentation and comments with no duplicated words or misspellings. Tests: - Not run - docs/comments only References: None - typo cleanup --- .../pekko/actor/testkit/typed/javadsl/BehaviorTestKit.scala | 2 +- .../org/apache/pekko/actor/testkit/typed/javadsl/TestInbox.scala | 2 +- .../org/apache/pekko/actor/testkit/typed/scaladsl/TestInbox.scala | 2 +- .../scala/org/apache/pekko/io/UdpConnectedIntegrationSpec.scala | 2 +- .../test/scala/org/apache/pekko/serialization/SerializeSpec.scala | 2 +- .../main/scala/org/apache/pekko/actor/typed/SpawnProtocol.scala | 2 +- .../delivery/internal/WorkPullingProducerControllerImpl.scala | 2 +- actor/src/main/resources/reference.conf | 2 +- actor/src/main/scala/org/apache/pekko/actor/Stash.scala | 2 +- .../scala/org/apache/pekko/actor/dungeon/TimerSchedulerImpl.scala | 2 +- .../cluster/sharding/typed/ShardedDaemonProcessSettings.scala | 2 +- .../typed/delivery/internal/ShardingProducerControllerImpl.scala | 2 +- .../sharding/typed/delivery/ReliableDeliveryShardingSpec.scala | 2 +- .../org/apache/pekko/cluster/sharding/ShardCoordinator.scala | 2 +- .../pekko/cluster/sharding/ConcurrentStartupShardingSpec.scala | 2 +- .../pekko/cluster/sharding/PersistentShardingMigrationSpec.scala | 2 +- .../apache/pekko/cluster/singleton/ClusterSingletonManager.scala | 2 +- .../cluster/ddata/typed/javadsl/ReplicatorMessageAdapter.scala | 8 ++++---- .../cluster/ddata/typed/scaladsl/ReplicatorMessageAdapter.scala | 8 ++++---- cluster/src/main/scala/org/apache/pekko/cluster/Cluster.scala | 4 ++-- .../main/scala/org/apache/pekko/cluster/sbr/DowningStrategy.scala | 2 +- .../org/apache/pekko/cluster/JoinConfigCompatCheckerSpec.scala | 4 ++-- .../scala/org/apache/pekko/cluster/ReachabilityPerfSpec.scala | 2 +- .../scala/org/apache/pekko/discovery/dns/DnsDiscoverySpec.scala | 2 +- .../main/scala/org/apache/pekko/cluster/ddata/Replicator.scala | 2 +- docs/src/main/paradox/discovery/index.md | 2 +- docs/src/main/paradox/serialization-jackson.md | 2 +- .../src/main/paradox/stream/operators/Source-or-Flow/alsoToAll.md | 2 +- docs/src/main/paradox/stream/stream-refs.md | 2 +- docs/src/main/paradox/typed/cluster-sharding.md | 2 +- docs/src/main/paradox/typed/cluster-singleton.md | 6 +++--- docs/src/main/paradox/typed/distributed-data.md | 2 +- docs/src/main/paradox/typed/persistence-snapshot.md | 2 +- docs/src/main/paradox/typed/persistence-testing.md | 2 +- docs/src/main/paradox/typed/style-guide.md | 2 +- .../pekko/persistence/typed/javadsl/PersistentFSMMigration.scala | 2 +- .../pekko/persistence/typed/scaladsl/PersistentFSMMigration.scala | 2 +- remote/src/main/resources/reference.conf | 2 +- .../apache/pekko/serialization/jackson/JacksonSerializer.scala | 2 +- .../apache/pekko/serialization/jackson3/JacksonSerializer.scala | 2 +- .../org/apache/pekko/stream/scaladsl/GraphUnzipWithSpec.scala | 2 +- .../test/scala/org/apache/pekko/stream/scaladsl/RestartSpec.scala | 4 ++-- .../src/test/scala/org/apache/pekko/testkit/PekkoSpecSpec.scala | 2 +- 43 files changed, 54 insertions(+), 54 deletions(-) diff --git a/actor-testkit-typed/src/main/scala/org/apache/pekko/actor/testkit/typed/javadsl/BehaviorTestKit.scala b/actor-testkit-typed/src/main/scala/org/apache/pekko/actor/testkit/typed/javadsl/BehaviorTestKit.scala index 2a97e31323..8057b0e8e6 100644 --- a/actor-testkit-typed/src/main/scala/org/apache/pekko/actor/testkit/typed/javadsl/BehaviorTestKit.scala +++ b/actor-testkit-typed/src/main/scala/org/apache/pekko/actor/testkit/typed/javadsl/BehaviorTestKit.scala @@ -177,7 +177,7 @@ abstract class BehaviorTestKit[T] { def expectEffect(expectedEffect: Effect): Unit /** - * Asserts that the oldest effect is an instance of of class T. Consumes and returns the concrete effect for + * Asserts that the oldest effect is an instance of class T. Consumes and returns the concrete effect for * further direct assertions. */ def expectEffectClass[U <: Effect](effectClass: Class[U]): U diff --git a/actor-testkit-typed/src/main/scala/org/apache/pekko/actor/testkit/typed/javadsl/TestInbox.scala b/actor-testkit-typed/src/main/scala/org/apache/pekko/actor/testkit/typed/javadsl/TestInbox.scala index bc4467aca4..69876fc9b4 100644 --- a/actor-testkit-typed/src/main/scala/org/apache/pekko/actor/testkit/typed/javadsl/TestInbox.scala +++ b/actor-testkit-typed/src/main/scala/org/apache/pekko/actor/testkit/typed/javadsl/TestInbox.scala @@ -62,7 +62,7 @@ abstract class TestInbox[T] { def receiveMessage(): T /** - * Assert and remove the the oldest message. + * Assert and remove the oldest message. */ def expectMessage(expectedMessage: T): TestInbox[T] diff --git a/actor-testkit-typed/src/main/scala/org/apache/pekko/actor/testkit/typed/scaladsl/TestInbox.scala b/actor-testkit-typed/src/main/scala/org/apache/pekko/actor/testkit/typed/scaladsl/TestInbox.scala index f619499835..8b9086344e 100644 --- a/actor-testkit-typed/src/main/scala/org/apache/pekko/actor/testkit/typed/scaladsl/TestInbox.scala +++ b/actor-testkit-typed/src/main/scala/org/apache/pekko/actor/testkit/typed/scaladsl/TestInbox.scala @@ -61,7 +61,7 @@ trait TestInbox[T] { def receiveMessage(): T /** - * Assert and remove the the oldest message. + * Assert and remove the oldest message. */ def expectMessage(expectedMessage: T): TestInbox[T] diff --git a/actor-tests/src/test/scala/org/apache/pekko/io/UdpConnectedIntegrationSpec.scala b/actor-tests/src/test/scala/org/apache/pekko/io/UdpConnectedIntegrationSpec.scala index d509c55958..686cd47136 100644 --- a/actor-tests/src/test/scala/org/apache/pekko/io/UdpConnectedIntegrationSpec.scala +++ b/actor-tests/src/test/scala/org/apache/pekko/io/UdpConnectedIntegrationSpec.scala @@ -162,7 +162,7 @@ class UdpConnectedIntegrationSpec extends PekkoSpec(""" clientCommander ! UdpConnected.Send(ByteString("data to trigger fail"), 2) expectMsg(2) - // when a new server appears at the same port it it should be able to receive + // when a new server appears at the same port it should be able to receive val serverIncarnation2Handler = TestProbe() val serverIncarnation2 = bindUdp(serverAddress, serverIncarnation2Handler.ref) val dataToNewIncarnation = ByteString("Data to new incarnation") diff --git a/actor-tests/src/test/scala/org/apache/pekko/serialization/SerializeSpec.scala b/actor-tests/src/test/scala/org/apache/pekko/serialization/SerializeSpec.scala index 4248da6a68..a94ba68368 100644 --- a/actor-tests/src/test/scala/org/apache/pekko/serialization/SerializeSpec.scala +++ b/actor-tests/src/test/scala/org/apache/pekko/serialization/SerializeSpec.scala @@ -223,7 +223,7 @@ class SerializeSpec extends PekkoSpec(SerializationTests.serializeConf) { ser.serializerFor(classOf[PlainMessage]).getClass should ===(classOf[NoopSerializer]) } - "resolve serializer for message extending class with with binding" in { + "resolve serializer for message extending class with binding" in { ser.serializerFor(classOf[ExtendedPlainMessage]).getClass should ===(classOf[NoopSerializer]) } diff --git a/actor-typed/src/main/scala/org/apache/pekko/actor/typed/SpawnProtocol.scala b/actor-typed/src/main/scala/org/apache/pekko/actor/typed/SpawnProtocol.scala index 3cab20efce..cf792d9a1c 100644 --- a/actor-typed/src/main/scala/org/apache/pekko/actor/typed/SpawnProtocol.scala +++ b/actor-typed/src/main/scala/org/apache/pekko/actor/typed/SpawnProtocol.scala @@ -47,7 +47,7 @@ object SpawnProtocol { * If `name` is an empty string an anonymous actor (with automatically generated name) will be created. * * If the `name` is already taken of an existing actor a unique name will be used by appending a suffix - * to the the `name`. The exact format or value of the suffix is an implementation detail that is + * to the `name`. The exact format or value of the suffix is an implementation detail that is * undefined. This means that reusing the same name for several actors will not result in * `InvalidActorNameException`, but it's better to use unique names to begin with. */ diff --git a/actor-typed/src/main/scala/org/apache/pekko/actor/typed/delivery/internal/WorkPullingProducerControllerImpl.scala b/actor-typed/src/main/scala/org/apache/pekko/actor/typed/delivery/internal/WorkPullingProducerControllerImpl.scala index 4821417087..2e8b008bee 100644 --- a/actor-typed/src/main/scala/org/apache/pekko/actor/typed/delivery/internal/WorkPullingProducerControllerImpl.scala +++ b/actor-typed/src/main/scala/org/apache/pekko/actor/typed/delivery/internal/WorkPullingProducerControllerImpl.scala @@ -664,7 +664,7 @@ private class WorkPullingProducerControllerImpl[A: ClassTag]( case AskTimeout(outKey, outSeqNr) => context.log.debug( - "Message seqNr [{}] sent to worker [{}] timed out. It will be be redelivered.", + "Message seqNr [{}] sent to worker [{}] timed out. It will be redelivered.", outSeqNr, outKey) Behaviors.same diff --git a/actor/src/main/resources/reference.conf b/actor/src/main/resources/reference.conf index 5b4add60f3..9a7cf7b62c 100644 --- a/actor/src/main/resources/reference.conf +++ b/actor/src/main/resources/reference.conf @@ -595,7 +595,7 @@ pekko { # If the current runtime does not support virtual thread, # then the executor configured in "fallback" will be used. virtual-thread-executor { - #Please set the the underlying pool with system properties below: + #Please set the underlying pool with system properties below: #jdk.virtualThreadScheduler.parallelism #jdk.virtualThreadScheduler.maxPoolSize #jdk.virtualThreadScheduler.minRunnable diff --git a/actor/src/main/scala/org/apache/pekko/actor/Stash.scala b/actor/src/main/scala/org/apache/pekko/actor/Stash.scala index 823253f0ab..104962a103 100644 --- a/actor/src/main/scala/org/apache/pekko/actor/Stash.scala +++ b/actor/src/main/scala/org/apache/pekko/actor/Stash.scala @@ -254,7 +254,7 @@ private[pekko] trait StashSupport { /** * INTERNAL API. * - * Clears the stash and and returns all envelopes that have not been unstashed. + * Clears the stash and returns all envelopes that have not been unstashed. */ @InternalStableApi private[pekko] def clearStash(): Vector[Envelope] = { diff --git a/actor/src/main/scala/org/apache/pekko/actor/dungeon/TimerSchedulerImpl.scala b/actor/src/main/scala/org/apache/pekko/actor/dungeon/TimerSchedulerImpl.scala index f5a973ef63..e1ea980f3c 100644 --- a/actor/src/main/scala/org/apache/pekko/actor/dungeon/TimerSchedulerImpl.scala +++ b/actor/src/main/scala/org/apache/pekko/actor/dungeon/TimerSchedulerImpl.scala @@ -149,7 +149,7 @@ import pekko.util.OptionVal } else { // it was from an old timer that was enqueued in mailbox before canceled log.debug( - "Received timer [{}] from from old generation [{}], expected generation [{}], discarding", + "Received timer [{}] from old generation [{}], expected generation [{}], discarding", timerMsg.key, timerMsg.generation, t.generation) diff --git a/cluster-sharding-typed/src/main/scala/org/apache/pekko/cluster/sharding/typed/ShardedDaemonProcessSettings.scala b/cluster-sharding-typed/src/main/scala/org/apache/pekko/cluster/sharding/typed/ShardedDaemonProcessSettings.scala index 3224d1674e..b64fc1930d 100644 --- a/cluster-sharding-typed/src/main/scala/org/apache/pekko/cluster/sharding/typed/ShardedDaemonProcessSettings.scala +++ b/cluster-sharding-typed/src/main/scala/org/apache/pekko/cluster/sharding/typed/ShardedDaemonProcessSettings.scala @@ -88,7 +88,7 @@ final class ShardedDaemonProcessSettings @InternalApi private[pekko] ( /** * Specifies that the ShardedDaemonProcess should run on nodes with a specific role. * If the role is not specified all nodes in the cluster are used. If the given role does - * not match the role of the current node the the ShardedDaemonProcess will not be started. + * not match the role of the current node the ShardedDaemonProcess will not be started. */ def withRole(role: String): ShardedDaemonProcessSettings = copy(role = Option(role)) diff --git a/cluster-sharding-typed/src/main/scala/org/apache/pekko/cluster/sharding/typed/delivery/internal/ShardingProducerControllerImpl.scala b/cluster-sharding-typed/src/main/scala/org/apache/pekko/cluster/sharding/typed/delivery/internal/ShardingProducerControllerImpl.scala index b105fcdf12..1778f005a0 100644 --- a/cluster-sharding-typed/src/main/scala/org/apache/pekko/cluster/sharding/typed/delivery/internal/ShardingProducerControllerImpl.scala +++ b/cluster-sharding-typed/src/main/scala/org/apache/pekko/cluster/sharding/typed/delivery/internal/ShardingProducerControllerImpl.scala @@ -573,7 +573,7 @@ private class ShardingProducerControllerImpl[A: ClassTag]( case AskTimeout(outKey, outSeqNr) => context.log.debug( - "Message seqNr [{}] sent to entity [{}] timed out. It will be be redelivered.", + "Message seqNr [{}] sent to entity [{}] timed out. It will be redelivered.", outSeqNr, outKey) Behaviors.same diff --git a/cluster-sharding-typed/src/test/scala/org/apache/pekko/cluster/sharding/typed/delivery/ReliableDeliveryShardingSpec.scala b/cluster-sharding-typed/src/test/scala/org/apache/pekko/cluster/sharding/typed/delivery/ReliableDeliveryShardingSpec.scala index 56a30704ee..e05cf0d23d 100644 --- a/cluster-sharding-typed/src/test/scala/org/apache/pekko/cluster/sharding/typed/delivery/ReliableDeliveryShardingSpec.scala +++ b/cluster-sharding-typed/src/test/scala/org/apache/pekko/cluster/sharding/typed/delivery/ReliableDeliveryShardingSpec.scala @@ -305,7 +305,7 @@ class ReliableDeliveryShardingSpec next8.entitiesWithDemand should ===(Set("entity-2")) next8.bufferedForEntitiesWithoutDemand should ===(Map("entity-1" -> 1)) - // when new demand the buffered messages will be be sent + // when new demand the buffered messages will be sent seq5.producerController ! ProducerControllerImpl.Request(confirmedSeqNr = 5L, requestUpToSeqNr = 10, true, false) val seq6 = shardingProbe .fishForMessage(testKit.testKitSettings.dilated(3.seconds), "waiting for buffered msg-6 after renewed demand") { diff --git a/cluster-sharding/src/main/scala/org/apache/pekko/cluster/sharding/ShardCoordinator.scala b/cluster-sharding/src/main/scala/org/apache/pekko/cluster/sharding/ShardCoordinator.scala index 538f5cde2d..b079f98d43 100644 --- a/cluster-sharding/src/main/scala/org/apache/pekko/cluster/sharding/ShardCoordinator.scala +++ b/cluster-sharding/src/main/scala/org/apache/pekko/cluster/sharding/ShardCoordinator.scala @@ -171,7 +171,7 @@ object ShardCoordinator { /** * Shard allocation strategy where start is called by the shard coordinator before any calls to * rebalance or allocate shard. This can be used if there is any expensive initialization to be done - * that you do not want to to in the constructor as it will happen on every node rather than just + * that you do not want to do in the constructor as it will happen on every node rather than just * the node that hosts the ShardCoordinator */ trait StartableAllocationStrategy extends ShardAllocationStrategy { diff --git a/cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/ConcurrentStartupShardingSpec.scala b/cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/ConcurrentStartupShardingSpec.scala index 37463335bc..ea8ae11bb4 100644 --- a/cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/ConcurrentStartupShardingSpec.scala +++ b/cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/ConcurrentStartupShardingSpec.scala @@ -78,7 +78,7 @@ class ConcurrentStartupShardingSpec extends PekkoSpec(ConcurrentStartupShardingS if (!log.isDebugEnabled) system.eventStream.publish(Mute(DeadLettersFilter[Any])) - // The intended usage is to start sharding in one (or a few) places when the the ActorSystem + // The intended usage is to start sharding in one (or a few) places when the ActorSystem // is started and not to do it concurrently from many threads. However, we can do our best and when using // FJP the Await will create additional threads when needed. "Concurrent Sharding startup" must { diff --git a/cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/PersistentShardingMigrationSpec.scala b/cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/PersistentShardingMigrationSpec.scala index 49edf1ccbf..6d7c4ced17 100644 --- a/cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/PersistentShardingMigrationSpec.scala +++ b/cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/PersistentShardingMigrationSpec.scala @@ -42,7 +42,7 @@ object PersistentShardingMigrationSpec { remember-entities-store = "eventsourced" # this forces the remembered entity store to use persistence - # is is deprecated + # is deprecated state-store-mode = "persistence" # make sure we test snapshots diff --git a/cluster-tools/src/main/scala/org/apache/pekko/cluster/singleton/ClusterSingletonManager.scala b/cluster-tools/src/main/scala/org/apache/pekko/cluster/singleton/ClusterSingletonManager.scala index 6a1a2bf6ee..0fca6107e3 100644 --- a/cluster-tools/src/main/scala/org/apache/pekko/cluster/singleton/ClusterSingletonManager.scala +++ b/cluster-tools/src/main/scala/org/apache/pekko/cluster/singleton/ClusterSingletonManager.scala @@ -219,7 +219,7 @@ object ClusterSingletonManager { case object HandOverDone extends ClusterSingletonMessage /** - * Sent from from previous oldest to new oldest to + * Sent from previous oldest to new oldest to * initiate the normal hand-over process. * Especially useful when new node joins and becomes * oldest immediately, without knowing who was previous diff --git a/cluster-typed/src/main/scala/org/apache/pekko/cluster/ddata/typed/javadsl/ReplicatorMessageAdapter.scala b/cluster-typed/src/main/scala/org/apache/pekko/cluster/ddata/typed/javadsl/ReplicatorMessageAdapter.scala index 3910c3b088..8fbaa0f835 100644 --- a/cluster-typed/src/main/scala/org/apache/pekko/cluster/ddata/typed/javadsl/ReplicatorMessageAdapter.scala +++ b/cluster-typed/src/main/scala/org/apache/pekko/cluster/ddata/typed/javadsl/ReplicatorMessageAdapter.scala @@ -101,7 +101,7 @@ class ReplicatorMessageAdapter[A, B <: ReplicatedData]( * `responseAdapter` function. * * Note that `createRequest` is a function that creates the `Update` message from the provided - * `ActorRef[UpdateResponse]` that the the replicator will send the response message back through. + * `ActorRef[UpdateResponse]` that the replicator will send the response message back through. * Use that `ActorRef[UpdateResponse]` as the `replyTo` parameter in the `Update` message. */ def askUpdate( @@ -120,7 +120,7 @@ class ReplicatorMessageAdapter[A, B <: ReplicatedData]( * `responseAdapter` function. * * Note that `createRequest` is a function that creates the `Get` message from the provided - * `ActorRef[GetResponse]` that the the replicator will send the response message back through. + * `ActorRef[GetResponse]` that the replicator will send the response message back through. * Use that `ActorRef[GetResponse]` as the `replyTo` parameter in the `Get` message. */ @nowarn @@ -140,7 +140,7 @@ class ReplicatorMessageAdapter[A, B <: ReplicatedData]( * `responseAdapter` function. * * Note that `createRequest` is a function that creates the `Delete` message from the provided - * `ActorRef[DeleteResponse]` that the the replicator will send the response message back through. + * `ActorRef[DeleteResponse]` that the replicator will send the response message back through. * Use that `ActorRef[DeleteResponse]` as the `replyTo` parameter in the `Delete` message. */ def askDelete( @@ -159,7 +159,7 @@ class ReplicatorMessageAdapter[A, B <: ReplicatedData]( * `responseAdapter` function. * * Note that `createRequest` is a function that creates the `GetReplicaCount` message from the provided - * `ActorRef[ReplicaCount]` that the the replicator will send the response message back through. + * `ActorRef[ReplicaCount]` that the replicator will send the response message back through. * Use that `ActorRef[ReplicaCount]` as the `replyTo` parameter in the `GetReplicaCount` message. */ def askReplicaCount( diff --git a/cluster-typed/src/main/scala/org/apache/pekko/cluster/ddata/typed/scaladsl/ReplicatorMessageAdapter.scala b/cluster-typed/src/main/scala/org/apache/pekko/cluster/ddata/typed/scaladsl/ReplicatorMessageAdapter.scala index 2544515e80..e30ba2a1fb 100644 --- a/cluster-typed/src/main/scala/org/apache/pekko/cluster/ddata/typed/scaladsl/ReplicatorMessageAdapter.scala +++ b/cluster-typed/src/main/scala/org/apache/pekko/cluster/ddata/typed/scaladsl/ReplicatorMessageAdapter.scala @@ -104,7 +104,7 @@ class ReplicatorMessageAdapter[A, B <: ReplicatedData]( * `responseAdapter` function. * * Note that `createRequest` is a function that creates the `Update` message from the provided - * `ActorRef[UpdateResponse]` that the the replicator will send the response message back through. + * `ActorRef[UpdateResponse]` that the replicator will send the response message back through. * Use that `ActorRef[UpdateResponse]` as the `replyTo` parameter in the `Update` message. */ def askUpdate( @@ -123,7 +123,7 @@ class ReplicatorMessageAdapter[A, B <: ReplicatedData]( * `responseAdapter` function. * * Note that `createRequest` is a function that creates the `Get` message from the provided - * `ActorRef[GetResponse]` that the the replicator will send the response message back through. + * `ActorRef[GetResponse]` that the replicator will send the response message back through. * Use that `ActorRef[GetResponse]` as the `replyTo` parameter in the `Get` message. */ def askGet( @@ -141,7 +141,7 @@ class ReplicatorMessageAdapter[A, B <: ReplicatedData]( * `responseAdapter` function. * * Note that `createRequest` is a function that creates the `Delete` message from the provided - * `ActorRef[DeleteResponse]` that the the replicator will send the response message back through. + * `ActorRef[DeleteResponse]` that the replicator will send the response message back through. * Use that `ActorRef[DeleteResponse]` as the `replyTo` parameter in the `Delete` message. */ def askDelete( @@ -160,7 +160,7 @@ class ReplicatorMessageAdapter[A, B <: ReplicatedData]( * `responseAdapter` function. * * Note that `createRequest` is a function that creates the `GetReplicaCount` message from the provided - * `ActorRef[ReplicaCount]` that the the replicator will send the response message back through. + * `ActorRef[ReplicaCount]` that the replicator will send the response message back through. * Use that `ActorRef[ReplicaCount]` as the `replyTo` parameter in the `GetReplicaCount` message. */ def askReplicaCount( diff --git a/cluster/src/main/scala/org/apache/pekko/cluster/Cluster.scala b/cluster/src/main/scala/org/apache/pekko/cluster/Cluster.scala index 1fd9bd911b..2a13a1a455 100644 --- a/cluster/src/main/scala/org/apache/pekko/cluster/Cluster.scala +++ b/cluster/src/main/scala/org/apache/pekko/cluster/Cluster.scala @@ -452,7 +452,7 @@ class Cluster(val system: ExtendedActorSystem) extends Extension { /** * The supplied thunk will be run, once, when current cluster member is `Removed`. * If the cluster has already been shutdown the thunk will run on the caller thread immediately. - * If this is called "at the same time" as `shutdown()` there is a possibility that the the thunk + * If this is called "at the same time" as `shutdown()` there is a possibility that the thunk * is not invoked. It's often better to use [[pekko.actor.CoordinatedShutdown]] for this purpose. */ def registerOnMemberRemoved[T](code: => T): Unit = @@ -461,7 +461,7 @@ class Cluster(val system: ExtendedActorSystem) extends Extension { /** * Java API: The supplied thunk will be run, once, when current cluster member is `Removed`. * If the cluster has already been shutdown the thunk will run on the caller thread immediately. - * If this is called "at the same time" as `shutdown()` there is a possibility that the the thunk + * If this is called "at the same time" as `shutdown()` there is a possibility that the thunk * is not invoked. It's often better to use [[pekko.actor.CoordinatedShutdown]] for this purpose. */ def registerOnMemberRemoved(callback: Runnable): Unit = { diff --git a/cluster/src/main/scala/org/apache/pekko/cluster/sbr/DowningStrategy.scala b/cluster/src/main/scala/org/apache/pekko/cluster/sbr/DowningStrategy.scala index 4de96915bf..ccc209d5e2 100644 --- a/cluster/src/main/scala/org/apache/pekko/cluster/sbr/DowningStrategy.scala +++ b/cluster/src/main/scala/org/apache/pekko/cluster/sbr/DowningStrategy.scala @@ -392,7 +392,7 @@ import pekko.coordination.lease.scaladsl.Lease * INTERNAL API * * Down the unreachable nodes if the current node is in the majority part based the last known - * membership information. Otherwise down the reachable nodes, i.e. the own part. If the the + * membership information. Otherwise down the reachable nodes, i.e. the own part. If the * parts are of equal size the part containing the node with the lowest address is kept. * * If the `role` is defined the decision is based only on members with that `role`. diff --git a/cluster/src/test/scala/org/apache/pekko/cluster/JoinConfigCompatCheckerSpec.scala b/cluster/src/test/scala/org/apache/pekko/cluster/JoinConfigCompatCheckerSpec.scala index 086a42f1e7..9677f2d459 100644 --- a/cluster/src/test/scala/org/apache/pekko/cluster/JoinConfigCompatCheckerSpec.scala +++ b/cluster/src/test/scala/org/apache/pekko/cluster/JoinConfigCompatCheckerSpec.scala @@ -234,7 +234,7 @@ class JoinConfigCompatCheckerSpec extends PekkoSpec with ClusterTestKit { "be allowed to join a cluster when its configuration is incompatible but it's configured to NOT enforce it" taggedAs LongRunningTest in { // this config is NOT compatible with the cluster config, - // but node will ignore the the config check and join anyway + // but node will ignore the config check and join anyway val joinNodeConfig = ConfigFactory.parseString(""" pekko.cluster { @@ -523,7 +523,7 @@ class JoinConfigCompatCheckerSpec extends PekkoSpec with ClusterTestKit { "be allowed to re-join a cluster when its configuration is incompatible but it's configured to NOT enforce it" taggedAs LongRunningTest in { // this config is NOT compatible with the cluster config, - // but node will ignore the the config check and join anyway + // but node will ignore the config check and join anyway val joinNodeConfig = ConfigFactory.parseString(""" pekko.cluster { diff --git a/cluster/src/test/scala/org/apache/pekko/cluster/ReachabilityPerfSpec.scala b/cluster/src/test/scala/org/apache/pekko/cluster/ReachabilityPerfSpec.scala index 471fb7f8a5..900f916ea6 100644 --- a/cluster/src/test/scala/org/apache/pekko/cluster/ReachabilityPerfSpec.scala +++ b/cluster/src/test/scala/org/apache/pekko/cluster/ReachabilityPerfSpec.scala @@ -92,7 +92,7 @@ class ReachabilityPerfSpec extends AnyWordSpec with Matchers { private def recordsFrom(r1: Reachability): Unit = { r1.allObservers.foreach { o => - r1.recordsFrom(o) should not be be(null) + r1.recordsFrom(o) should not be (null) } } diff --git a/discovery/src/test/scala/org/apache/pekko/discovery/dns/DnsDiscoverySpec.scala b/discovery/src/test/scala/org/apache/pekko/discovery/dns/DnsDiscoverySpec.scala index 73a9115c27..75f2205230 100644 --- a/discovery/src/test/scala/org/apache/pekko/discovery/dns/DnsDiscoverySpec.scala +++ b/discovery/src/test/scala/org/apache/pekko/discovery/dns/DnsDiscoverySpec.scala @@ -115,7 +115,7 @@ class DnsDiscoverySpec extends DockerBindDnsService(DnsDiscoverySpec.config) { } "be using its own resolver" in { - // future will fail if it it doesn't exist + // future will fail if it doesn't exist system.actorSelection("/system/SD-DNS/async-dns").resolveOne(2.seconds).futureValue } diff --git a/distributed-data/src/main/scala/org/apache/pekko/cluster/ddata/Replicator.scala b/distributed-data/src/main/scala/org/apache/pekko/cluster/ddata/Replicator.scala index f9f3f996da..37f622c2ce 100644 --- a/distributed-data/src/main/scala/org/apache/pekko/cluster/ddata/Replicator.scala +++ b/distributed-data/src/main/scala/org/apache/pekko/cluster/ddata/Replicator.scala @@ -1101,7 +1101,7 @@ object Replicator { * * For good introduction to the CRDT subject watch the * <a href="https://www.infoq.com/presentations/CRDT/";>Eventually Consistent Data Structures</a> - * talk by Sean Cribbs and and the + * talk by Sean Cribbs and the * <a href="https://www.microsoft.com/en-us/research/video/strong-eventual-consistency-and-conflict-free-replicated-data-types/";>talk by Mark Shapiro</a> * and read the excellent paper <a href="https://hal.inria.fr/file/index/docid/555588/filename/techreport.pdf";> * A comprehensive study of Convergent and Commutative Replicated Data Types</a> diff --git a/docs/src/main/paradox/discovery/index.md b/docs/src/main/paradox/discovery/index.md index 9665314174..fda23ccbdc 100644 --- a/docs/src/main/paradox/discovery/index.md +++ b/docs/src/main/paradox/discovery/index.md @@ -74,7 +74,7 @@ Pekko Discovery with DNS does always use the @ref[Pekko-native "async-dns" imple DNS discovery maps `Lookup` queries as follows: * `serviceName`, `portName` and `protocol` set: SRV query in the form: `_port._protocol.name` Where the `_`s are added. -* Any query missing any of the fields is mapped to a A/AAAA query for the `serviceName` +* Any query missing any of the fields is mapped to a A/AAAA query for the `serviceName` The mapping between Pekko service discovery terminology and SRV terminology: diff --git a/docs/src/main/paradox/serialization-jackson.md b/docs/src/main/paradox/serialization-jackson.md index 108a753043..b5d8fa5271 100644 --- a/docs/src/main/paradox/serialization-jackson.md +++ b/docs/src/main/paradox/serialization-jackson.md @@ -18,7 +18,7 @@ To use Jackson Serialization, you must add the following dependency in your proj ## Introduction -You find general concepts for for Pekko serialization in the @ref:[Serialization](serialization.md) section. +You find general concepts for Pekko serialization in the @ref:[Serialization](serialization.md) section. This section describes how to use the Jackson serializer for application specific messages and persistent events and snapshots. diff --git a/docs/src/main/paradox/stream/operators/Source-or-Flow/alsoToAll.md b/docs/src/main/paradox/stream/operators/Source-or-Flow/alsoToAll.md index 29951f9ed6..b2650a8c6c 100644 --- a/docs/src/main/paradox/stream/operators/Source-or-Flow/alsoToAll.md +++ b/docs/src/main/paradox/stream/operators/Source-or-Flow/alsoToAll.md @@ -24,7 +24,7 @@ will also be sent to all those @apidoc[Sink]s. **completes** when upstream completes -**cancels** when downstream or or any of the @apidoc[Sink]s cancels +**cancels** when downstream or any of the @apidoc[Sink]s cancels @@@ diff --git a/docs/src/main/paradox/stream/stream-refs.md b/docs/src/main/paradox/stream/stream-refs.md index 40d5f5e019..1f3e5d795c 100644 --- a/docs/src/main/paradox/stream/stream-refs.md +++ b/docs/src/main/paradox/stream/stream-refs.md @@ -158,7 +158,7 @@ Stream refs utilise normal actor messaging for their transport, and therefore pr - messages are sent over actor remoting - which relies on TCP (classic remoting or Artery TCP) or Aeron UDP for basic redelivery mechanisms -- messages are guaranteed to to be in-order +- messages are guaranteed to be in-order - messages can be lost, however: - a *dropped demand signal* will be re-delivered automatically (similar to system messages) - a *dropped element signal* will cause the stream to *fail* diff --git a/docs/src/main/paradox/typed/cluster-sharding.md b/docs/src/main/paradox/typed/cluster-sharding.md index 7a442e1cef..1192a2ce5e 100644 --- a/docs/src/main/paradox/typed/cluster-sharding.md +++ b/docs/src/main/paradox/typed/cluster-sharding.md @@ -776,7 +776,7 @@ Reasons for how this can happen: A lease can be a final backup that means that each shard won't create child entity actors unless it has the lease. To use a lease for sharding set `pekko.cluster.sharding.use-lease` to the configuration location -of the lease to use. Each shard will try and acquire a lease with with the name `<actor system name>-shard-<type name>-<shard id>` and +of the lease to use. Each shard will try and acquire a lease with the name `<actor system name>-shard-<type name>-<shard id>` and the owner is set to the `Cluster(system).selfAddress.hostPort`. If a shard can't acquire a lease it will remain uninitialized so messages for entities it owns will diff --git a/docs/src/main/paradox/typed/cluster-singleton.md b/docs/src/main/paradox/typed/cluster-singleton.md index c705ad9403..e6c482d313 100644 --- a/docs/src/main/paradox/typed/cluster-singleton.md +++ b/docs/src/main/paradox/typed/cluster-singleton.md @@ -38,7 +38,7 @@ instance will eventually be started. @@@ warning Make sure to not use a Cluster downing strategy that may split the cluster into several separate clusters in -case of network problems or system overload (long GC pauses), since that will result in in *multiple Singletons* +case of network problems or system overload (long GC pauses), since that will result in *multiple Singletons* being started, one in each separate cluster! See @ref:[Downing](cluster.md#downing). @@ -106,7 +106,7 @@ This pattern may seem to be very tempting to use at first, but it has several dr @@@ warning Make sure to not use a Cluster downing strategy that may split the cluster into several separate clusters in -case of network problems or system overload (long GC pauses), since that will result in in *multiple Singletons* +case of network problems or system overload (long GC pauses), since that will result in *multiple Singletons* being started, one in each separate cluster! See @ref:[Downing](cluster.md#downing). @@ -175,7 +175,7 @@ A lease can be a final backup that means that the singleton actor won't be creat the lease can be acquired. To use a lease for singleton set `pekko.cluster.singleton.use-lease` to the configuration location -of the lease to use. A lease with with the name `<actor system name>-singleton-<singleton actor path>` is used and +of the lease to use. A lease with the name `<actor system name>-singleton-<singleton actor path>` is used and the owner is set to the @scala[`Cluster(system).selfAddress.hostPort`]@java[`Cluster.get(system).selfAddress().hostPort()`]. If the cluster singleton manager can't acquire the lease it will keep retrying while it is the oldest node in the cluster. diff --git a/docs/src/main/paradox/typed/distributed-data.md b/docs/src/main/paradox/typed/distributed-data.md index 84a4104bad..b87ee83822 100644 --- a/docs/src/main/paradox/typed/distributed-data.md +++ b/docs/src/main/paradox/typed/distributed-data.md @@ -561,7 +561,7 @@ Note that the full state is occasionally also replicated for delta-CRDTs, for ex new nodes are added to the cluster or when deltas could not be propagated because of network partitions or similar problems. -The the delta propagation can be disabled with configuration property: +The delta propagation can be disabled with configuration property: ``` pekko.cluster.distributed-data.delta-crdt.enabled=off diff --git a/docs/src/main/paradox/typed/persistence-snapshot.md b/docs/src/main/paradox/typed/persistence-snapshot.md index bfc2112d23..799a0932c8 100644 --- a/docs/src/main/paradox/typed/persistence-snapshot.md +++ b/docs/src/main/paradox/typed/persistence-snapshot.md @@ -52,7 +52,7 @@ events. This can be useful if snapshot serialization format has changed in an in not be used when events have been deleted. In order to use snapshots, a default snapshot-store (`pekko.persistence.snapshot-store.plugin`) must be configured, -or you can pick a snapshot store for for a specific `EventSourcedBehavior` by +or you can pick a snapshot store for a specific `EventSourcedBehavior` by @scala[defining it with `withSnapshotPluginId` of the `EventSourcedBehavior`]@java[overriding `snapshotPluginId` in the `EventSourcedBehavior`]. diff --git a/docs/src/main/paradox/typed/persistence-testing.md b/docs/src/main/paradox/typed/persistence-testing.md index 17ecd576f4..17fe88475f 100644 --- a/docs/src/main/paradox/typed/persistence-testing.md +++ b/docs/src/main/paradox/typed/persistence-testing.md @@ -59,7 +59,7 @@ Java `PersistenceProbeBehavior` does not require any configuration. It therefore does not verify the serialization of commands, events, or state. If using this style, it is advised to independently test serialization for those classes. -## Unit testing with the the ActorTestKit and EventSourcedBehaviorTestKit +## Unit testing with the ActorTestKit and EventSourcedBehaviorTestKit **Note!** The `EventSourcedBehaviorTestKit` is a new feature: the API may have changes breaking source compatibility in future versions. diff --git a/docs/src/main/paradox/typed/style-guide.md b/docs/src/main/paradox/typed/style-guide.md index 0b90acf6c9..1a23d97728 100644 --- a/docs/src/main/paradox/typed/style-guide.md +++ b/docs/src/main/paradox/typed/style-guide.md @@ -45,7 +45,7 @@ A few differences to note: * There is no class in the functional style, but that is not strictly a requirement and sometimes it's convenient to use a class also with the functional style to reduce number of parameters in the methods. * Mutable state, such as the @scala[`var n`]@java[`int n`] is typically used in the object-oriented style. -* In the functional style the state is is updated by returning a new behavior that holds the new immutable state, +* In the functional style the state is updated by returning a new behavior that holds the new immutable state, the @scala[`n: Int`]@java[`final int n`] parameter of the `counter` method. * The object-oriented style must use a new instance of the initial `Behavior` for each spawned actor instance, since the state in `AbstractBehavior` instance must not be shared between actor instances. diff --git a/persistence-typed/src/main/scala/org/apache/pekko/persistence/typed/javadsl/PersistentFSMMigration.scala b/persistence-typed/src/main/scala/org/apache/pekko/persistence/typed/javadsl/PersistentFSMMigration.scala index e97c1894b2..0d6266bf38 100644 --- a/persistence-typed/src/main/scala/org/apache/pekko/persistence/typed/javadsl/PersistentFSMMigration.scala +++ b/persistence-typed/src/main/scala/org/apache/pekko/persistence/typed/javadsl/PersistentFSMMigration.scala @@ -32,7 +32,7 @@ object PersistentFSMMigration { * Create a snapshot adapter that will adapt snapshots created by a PersistentFSM into * the correct State type of a [[EventSourcedBehavior]] * @param adapt Takes in the state identifier, snapshot persisted by the PersistentFSM and the state timeout and - * returns the `State` that should be given to the the [[EventSourcedBehavior]] + * returns the `State` that should be given to the [[EventSourcedBehavior]] * @tparam State State type of the [[EventSourcedBehavior]] * @return A [[SnapshotAdapter]] to be used with a [[EventSourcedBehavior]] */ diff --git a/persistence-typed/src/main/scala/org/apache/pekko/persistence/typed/scaladsl/PersistentFSMMigration.scala b/persistence-typed/src/main/scala/org/apache/pekko/persistence/typed/scaladsl/PersistentFSMMigration.scala index dda90f75e2..1cbf619701 100644 --- a/persistence-typed/src/main/scala/org/apache/pekko/persistence/typed/scaladsl/PersistentFSMMigration.scala +++ b/persistence-typed/src/main/scala/org/apache/pekko/persistence/typed/scaladsl/PersistentFSMMigration.scala @@ -28,7 +28,7 @@ object PersistentFSMMigration { * Create a snapshot adapter that will adapt snapshots created by a PersistentFSM into * the correct State type of a [[EventSourcedBehavior]] * @param adapt Takes in the state identifier, snapshot persisted by the PersistentFSM and the state timeout and - * returns the `State` that should be given to the the [[EventSourcedBehavior]] + * returns the `State` that should be given to the [[EventSourcedBehavior]] * @tparam State State type of the [[EventSourcedBehavior]] * @return A [[SnapshotAdapter]] to be used with a [[EventSourcedBehavior]] */ diff --git a/remote/src/main/resources/reference.conf b/remote/src/main/resources/reference.conf index 2741292ad9..b4bf9bac8e 100644 --- a/remote/src/main/resources/reference.conf +++ b/remote/src/main/resources/reference.conf @@ -1235,7 +1235,7 @@ pekko { # at least one common subject name (CN or SAN). # The Key setup this implementation supports has some limitations: # 1. the private key must be provided on a PKCS#1 or a non-encrypted PKCS#8 PEM-formatted file - # 2. the private key must be be of an algorithm supported by `pekko-pki` tools (e.g. "RSA", not "EC") + # 2. the private key must be of an algorithm supported by `pekko-pki` tools (e.g. "RSA", not "EC") # 3. the node certificate must be issued by a root CA (not an intermediate CA) # 4. both the node and the CA certificates must be provided in PEM-formatted files rotating-keys-engine { diff --git a/serialization-jackson/src/main/scala/org/apache/pekko/serialization/jackson/JacksonSerializer.scala b/serialization-jackson/src/main/scala/org/apache/pekko/serialization/jackson/JacksonSerializer.scala index 85ccf11ccf..7c3aac2030 100644 --- a/serialization-jackson/src/main/scala/org/apache/pekko/serialization/jackson/JacksonSerializer.scala +++ b/serialization-jackson/src/main/scala/org/apache/pekko/serialization/jackson/JacksonSerializer.scala @@ -175,7 +175,7 @@ import pekko.util.OptionVal * Configuration in `pekko.serialization.jackson` section. * It will load Jackson modules defined in configuration `jackson-modules`. * - * It will compress the payload if the compression `algorithm` is enabled and the the + * It will compress the payload if the compression `algorithm` is enabled and the * payload is larger than the configured `compress-larger-than` value. */ @InternalApi private[pekko] abstract class JacksonSerializer( diff --git a/serialization-jackson3/src/main/scala/org/apache/pekko/serialization/jackson3/JacksonSerializer.scala b/serialization-jackson3/src/main/scala/org/apache/pekko/serialization/jackson3/JacksonSerializer.scala index 1fc675f6d9..01c15ce4d8 100644 --- a/serialization-jackson3/src/main/scala/org/apache/pekko/serialization/jackson3/JacksonSerializer.scala +++ b/serialization-jackson3/src/main/scala/org/apache/pekko/serialization/jackson3/JacksonSerializer.scala @@ -175,7 +175,7 @@ import pekko.util.OptionVal * Configuration in `pekko.serialization.jackson` section. * It will load Jackson modules defined in configuration `jackson-modules`. * - * It will compress the payload if the compression `algorithm` is enabled and the the + * It will compress the payload if the compression `algorithm` is enabled and the * payload is larger than the configured `compress-larger-than` value. */ @InternalApi private[pekko] abstract class JacksonSerializer( diff --git a/stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/GraphUnzipWithSpec.scala b/stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/GraphUnzipWithSpec.scala index c9d8be38d9..159b5c1611 100644 --- a/stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/GraphUnzipWithSpec.scala +++ b/stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/GraphUnzipWithSpec.scala @@ -207,7 +207,7 @@ class GraphUnzipWithSpec extends StreamSpec(""" rightProbe.expectNoMessage(100.millis) } - "propagagate last downstream cancellation cause once all downstreams have cancelled" in { + "propagate last downstream cancellation cause once all downstreams have cancelled" in { val probe = TestProbe() RunnableGraph .fromGraph(GraphDSL.create() { implicit b => diff --git a/stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/RestartSpec.scala b/stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/RestartSpec.scala index 802cd438e9..726f9d382c 100644 --- a/stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/RestartSpec.scala +++ b/stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/RestartSpec.scala @@ -176,7 +176,7 @@ class RestartSpec probe.requestNext("a") probe.requestNext("b") probe.request(1) - // The probe should now be backing off again with with increased backoff + // The probe should now be backing off again with increased backoff // Now wait for the delay to pass, then it will start the new source, we also want to wait for the // subsequent backoff to pass, so it resets the restart count @@ -314,7 +314,7 @@ class RestartSpec probe.requestNext("a") // There should be minBackoff delay probe.requestNext("a") - // The probe should now be backing off again with with increased backoff + // The probe should now be backing off again with increased backoff // Now wait for the delay to pass, then it will start the new source, we also want to wait for the // subsequent backoff to pass diff --git a/testkit/src/test/scala/org/apache/pekko/testkit/PekkoSpecSpec.scala b/testkit/src/test/scala/org/apache/pekko/testkit/PekkoSpecSpec.scala index e353d09fd8..c833e4fc27 100644 --- a/testkit/src/test/scala/org/apache/pekko/testkit/PekkoSpecSpec.scala +++ b/testkit/src/test/scala/org/apache/pekko/testkit/PekkoSpecSpec.scala @@ -46,7 +46,7 @@ class PekkoSpecSpec extends AnyWordSpec with Matchers { } "terminate all actors" in { - // verbose config just for demonstration purposes, please leave in in case of debugging + // verbose config just for demonstration purposes, please leave in case of debugging import scala.jdk.CollectionConverters._ val conf = Map( "pekko.actor.debug.lifecycle" -> true, --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
