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

docs: fix ConsumerController java doc (#31472)

Browse source 
* fix ConsumerController java doc

* another java doc fix
This commit is contained in:
AndyChen 2022-08-15 15:13:08 +08:00 • committed by GitHub
parent 06eb8e29d9
commit ef3bd0278b
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

4
akka-actor-typed/src/main/scala/akka/actor/typed/delivery/ConsumerController.scala
View file

@ -58,7 +58,7 @@ object ConsumerController {
* Initial message from the consumer actor. The `deliverTo` is typically constructed
* as a message adapter to map the [[Delivery]] to the protocol of the consumer actor.
*
* If the producer is restarted it should send a new `Start` message to the
* If the consumer is restarted it should send a new `Start` message to the
* `ConsumerController`.
*/
final case class Start[A](deliverTo: ActorRef[Delivery[A]]) extends Command[A]
@ -114,7 +114,7 @@ object ConsumerController {
/**
* Register the `ConsumerController` to the given `producerController`. It will
* retry the registration until the `ProducerConsumer` has acknowledged by sending its
* retry the registration until the `ProducerController` has acknowledged by sending its
* first message.
*
* Alternatively, this registration can be done on the producer side with the