Package org.apache.pekko.cluster.sharding.typed.delivery
-
Interface Summary Interface Description ShardingProducerController.Command<A> -
Class Summary Class Description ShardingConsumerController ShardingConsumerController
is used together withShardingProducerController
.ShardingConsumerController.Settings ShardingConsumerController.Settings$ ShardingConsumerController$ ShardingConsumerController
is used together withShardingProducerController
.ShardingProducerController Reliable delivery between a producer actor sending messages to sharded consumer actors receiving the messages.ShardingProducerController.MessageWithConfirmation<A> For sending confirmation message back to the producer when the message has been confirmed.ShardingProducerController.MessageWithConfirmation$ ShardingProducerController.RequestNext<A> TheProducerController
sendsRequestNext
to the producer when it is allowed to send one message via thesendNextTo
oraskNextTo
.ShardingProducerController.RequestNext$ ShardingProducerController.Settings ShardingProducerController.Settings$ ShardingProducerController.Start<A> Initial message from the producer actor.ShardingProducerController.Start$ ShardingProducerController$ Reliable delivery between a producer actor sending messages to sharded consumer actors receiving the messages.