raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 11

Corrected several misspellings of the word "losing".

Browse source
This commit is contained in:
Brendan McAdams 2016-01-15 20:20:15 -08:00
parent ecc916abfd
commit 269a3b3647
6 changed files with 8 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-cluster-sharding/src/main/scala/akka/cluster/sharding/ClusterSharding.scala
View file

@ -128,7 +128,7 @@ import akka.dispatch.Dispatchers
* reduce memory consumption. This is done by the application specific implementation of * reduce memory consumption. This is done by the application specific implementation of
* the entity actors for example by defining receive timeout (`context.setReceiveTimeout`). * the entity actors for example by defining receive timeout (`context.setReceiveTimeout`).
* If a message is already enqueued to the entity when it stops itself the enqueued message * If a message is already enqueued to the entity when it stops itself the enqueued message
* in the mailbox will be dropped. To support graceful passivation without loosing such * in the mailbox will be dropped. To support graceful passivation without losing such
* messages the entity actor can send [[ShardRegion.Passivate]] to its parent `ShardRegion`. * messages the entity actor can send [[ShardRegion.Passivate]] to its parent `ShardRegion`.
* The specified wrapped message in `Passivate` will be sent back to the entity, which is * The specified wrapped message in `Passivate` will be sent back to the entity, which is
* then supposed to stop itself. Incoming messages will be buffered by the `ShardRegion` * then supposed to stop itself. Incoming messages will be buffered by the `ShardRegion`

2
akka-cluster-sharding/src/main/scala/akka/cluster/sharding/ShardRegion.scala
View file

@ -135,7 +135,7 @@ object ShardRegion {
* reduce memory consumption. This is done by the application specific implementation of * reduce memory consumption. This is done by the application specific implementation of
* the entity actors for example by defining receive timeout (`context.setReceiveTimeout`). * the entity actors for example by defining receive timeout (`context.setReceiveTimeout`).
* If a message is already enqueued to the entity when it stops itself the enqueued message * If a message is already enqueued to the entity when it stops itself the enqueued message
* in the mailbox will be dropped. To support graceful passivation without loosing such * in the mailbox will be dropped. To support graceful passivation without losing such
* messages the entity actor can send this `Passivate` message to its parent `ShardRegion`. * messages the entity actor can send this `Passivate` message to its parent `ShardRegion`.
* The specified wrapped `stopMessage` will be sent back to the entity, which is * The specified wrapped `stopMessage` will be sent back to the entity, which is
* then supposed to stop itself. Incoming messages will be buffered by the `ShardRegion` * then supposed to stop itself. Incoming messages will be buffered by the `ShardRegion`

2
akka-cluster/src/test/scala/akka/cluster/AutoDownSpec.scala
View file

@ -88,7 +88,7 @@ class AutoDownSpec extends AkkaSpec {
expectMsg(DownCalled(memberC.address)) expectMsg(DownCalled(memberC.address))
} }
"not down unreachable when loosing leadership inbetween detection and specified duration" in { "not down unreachable when losing leadership inbetween detection and specified duration" in {
val a = autoDownActor(2.seconds) val a = autoDownActor(2.seconds)
a ! LeaderChanged(Some(memberA.address)) a ! LeaderChanged(Some(memberA.address))
a ! UnreachableMember(memberC) a ! UnreachableMember(memberC)

4
akka-docs/rst/java/cluster-sharding.rst
View file

@ -214,7 +214,7 @@ If the state of the entities are persistent you may stop entities that are not u
reduce memory consumption. This is done by the application specific implementation of reduce memory consumption. This is done by the application specific implementation of
the entity actors for example by defining receive timeout (``context.setReceiveTimeout``). the entity actors for example by defining receive timeout (``context.setReceiveTimeout``).
If a message is already enqueued to the entity when it stops itself the enqueued message If a message is already enqueued to the entity when it stops itself the enqueued message
in the mailbox will be dropped. To support graceful passivation without loosing such in the mailbox will be dropped. To support graceful passivation without losing such
messages the entity actor can send ``ShardRegion.Passivate`` to its parent ``Shard``. messages the entity actor can send ``ShardRegion.Passivate`` to its parent ``Shard``.
The specified wrapped message in ``Passivate`` will be sent back to the entity, which is The specified wrapped message in ``Passivate`` will be sent back to the entity, which is
then supposed to stop itself. Incoming messages will be buffered by the ``Shard`` then supposed to stop itself. Incoming messages will be buffered by the ``Shard``
@ -357,4 +357,4 @@ a ``ClusterShard.ClusterShardingStats`` containing the identifiers of the shards
of entities that are alive in each shard. of entities that are alive in each shard.
The purpose of these messages is testing and monitoring, they are not provided to give access to The purpose of these messages is testing and monitoring, they are not provided to give access to
directly sending messages to the individual entities. directly sending messages to the individual entities.

4
akka-docs/rst/scala/cluster-sharding.rst
View file

@ -217,7 +217,7 @@ If the state of the entities are persistent you may stop entities that are not u
reduce memory consumption. This is done by the application specific implementation of reduce memory consumption. This is done by the application specific implementation of
the entity actors for example by defining receive timeout (``context.setReceiveTimeout``). the entity actors for example by defining receive timeout (``context.setReceiveTimeout``).
If a message is already enqueued to the entity when it stops itself the enqueued message If a message is already enqueued to the entity when it stops itself the enqueued message
in the mailbox will be dropped. To support graceful passivation without loosing such in the mailbox will be dropped. To support graceful passivation without losing such
messages the entity actor can send ``ShardRegion.Passivate`` to its parent ``Shard``. messages the entity actor can send ``ShardRegion.Passivate`` to its parent ``Shard``.
The specified wrapped message in ``Passivate`` will be sent back to the entity, which is The specified wrapped message in ``Passivate`` will be sent back to the entity, which is
then supposed to stop itself. Incoming messages will be buffered by the ``Shard`` then supposed to stop itself. Incoming messages will be buffered by the ``Shard``
@ -358,4 +358,4 @@ a ``ClusterShard.ClusterShardingStats`` containing the identifiers of the shards
of entities that are alive in each shard. of entities that are alive in each shard.
The purpose of these messages is testing and monitoring, they are not provided to give access to The purpose of these messages is testing and monitoring, they are not provided to give access to
directly sending messages to the individual entities. directly sending messages to the individual entities.

2
akka-samples/akka-sample-fsm-scala/src/main/scala/sample/redelivery/FsmSimpleRedelivery.scala
View file

@ -136,7 +136,7 @@ object Receiver {
class Receiver extends Actor { class Receiver extends Actor {
/** /**
* Simulate loosing 75% of all messages on the receiving end. We want to see the redelivery in action! * Simulate losing 75% of all messages on the receiving end. We want to see the redelivery in action!
*/ */
def shouldSendAck = ThreadLocalRandom.current.nextDouble() < 0.25 def shouldSendAck = ThreadLocalRandom.current.nextDouble() < 0.25