Add DistributedPubSub message guarantee in doc (Fixes #21441) (#21713)

This commit is contained in:
Richard Imaoka 2016-10-24 19:21:07 +09:00 committed by Konrad Malawski
parent 679db55eca
commit afa92f9209
3 changed files with 20 additions and 2 deletions

View file

@ -179,6 +179,15 @@ and then it takes a while for it to be populated.
akka.extensions = ["akka.cluster.pubsub.DistributedPubSub"]
Delivery Guarantee
------------------
As in :ref:`message-general-rules` of Akka, message delivery guarantee in distributed pub sub modes is **at-most-once delivery**.
In other words, messages can be lost over the wire.
If you are looking for at-least-once delivery guarantee, we recommend `Kafka Akka Streams integration <https://github.com/akka/reactive-kafka>`_.
Dependencies
------------

View file

@ -48,7 +48,7 @@ Actors are registered to a named topic. This enables many subscribers on each no
The message will be delivered to all subscribers of the topic.
For efficiency the message is sent over the wire only once per node (that has a matching topic),
and then delivered to all subscribers of the local topic representation.
and then delivered to all subscribers of the local topic representation. (See more in )
You register actors to the local mediator with ``DistributedPubSubMediator.Subscribe``.
Successful ``Subscribe`` and ``Unsubscribe`` is acknowledged with
@ -182,6 +182,15 @@ and then it takes a while for it to be populated.
akka.extensions = ["akka.cluster.pubsub.DistributedPubSub"]
Delivery Guarantee
------------------
As in :ref:`message-general-rules` of Akka, message delivery guarantee in distributed pub sub modes is **at-most-once delivery**.
In other words, messages can be lost over the wire.
If you are looking for at-least-once delivery guarantee, we recommend `Kafka Akka Streams integration <https://github.com/akka/reactive-kafka>`_.
Dependencies
------------
@ -198,3 +207,4 @@ maven::
<artifactId>akka-cluster-tools_@binVersion@</artifactId>
<version>@version@</version>
</dependency>

View file

@ -103,7 +103,6 @@ case "$1" in
ensureNodeIsRunningAndAvailable
echo "Querying cluster status"
get ClusterStatus
;;