Package org.apache.pekko.actor.typed.delivery

package org.apache.pekko.actor.typed.delivery

Related Packages

Package	Description
org.apache.pekko.actor.typed
org.apache.pekko.actor.typed.delivery.internal

Class	Description
ConsumerController	ConsumerController and ProducerController or WorkPullingProducerController are used together.
ConsumerController.Command<A>
ConsumerController.Confirmed
ConsumerController.Confirmed$	When the message has been processed the consumer is supposed to send Confirmed back to the ConsumerController via the confirmTo in the ConsumerController.Delivery message.
ConsumerController.DeliverThenStop<A>
ConsumerController.DeliverThenStop$
ConsumerController.Delivery<A>	Received messages from the producer are wrapped in Delivery when sent to the consumer.
ConsumerController.Delivery$
ConsumerController.RegisterToProducerController<A>	Register the ConsumerController to the given producerController.
ConsumerController.RegisterToProducerController$
ConsumerController.SequencedMessage<A>
ConsumerController.SequencedMessage$
ConsumerController.Settings
ConsumerController.Settings$
ConsumerController.Start<A>	Initial message from the consumer actor.
ConsumerController.Start$
ConsumerController$	ConsumerController and ProducerController or WorkPullingProducerController are used together.
DurableProducerQueue	Actor message protocol for storing and confirming reliable delivery of messages.
DurableProducerQueue.Cleanup$
DurableProducerQueue.Command<A>
DurableProducerQueue.Confirmed$
DurableProducerQueue.Event	INTERNAL API
DurableProducerQueue.LoadState<A>	Request that is used at startup to retrieve the unconfirmed messages and current sequence number.
DurableProducerQueue.LoadState$
DurableProducerQueue.MessageSent<A>	The fact (event) that a message has been sent.
DurableProducerQueue.MessageSent$
DurableProducerQueue.State<A>
DurableProducerQueue.State$
DurableProducerQueue.StoreMessageConfirmed<A>	Store the fact that a message has been confirmed to be delivered and processed.
DurableProducerQueue.StoreMessageConfirmed$
DurableProducerQueue.StoreMessageSent<A>	Store the fact that a message is to be sent.
DurableProducerQueue.StoreMessageSent$
DurableProducerQueue.StoreMessageSentAck
DurableProducerQueue.StoreMessageSentAck$
DurableProducerQueue$	Actor message protocol for storing and confirming reliable delivery of messages.
ProducerController	Point-to-point reliable delivery between a single producer actor sending messages and a single consumer actor receiving the messages.
ProducerController.Command<A>
ProducerController.MessageWithConfirmation<A>	For sending confirmation message back to the producer when the message has been confirmed.
ProducerController.MessageWithConfirmation$
ProducerController.RegisterConsumer<A>	Register the given consumerController to the ProducerController.
ProducerController.RegisterConsumer$
ProducerController.RequestNext<A>	The ProducerController sends RequestNext to the producer when it is allowed to send one message via the sendNextTo or askNextTo.
ProducerController.RequestNext$
ProducerController.Settings
ProducerController.Settings$
ProducerController.Start<A>	Initial message from the producer actor.
ProducerController.Start$
ProducerController$	Point-to-point reliable delivery between a single producer actor sending messages and a single consumer actor receiving the messages.
WorkPullingProducerController	Work pulling is a pattern where several worker actors pull tasks in their own pace from a shared work manager instead of that the manager pushes work to the workers blindly without knowing their individual capacity and current availability.
WorkPullingProducerController.Command<A>
WorkPullingProducerController.GetWorkerStats<A>	Retrieve information about registered workers.
WorkPullingProducerController.GetWorkerStats$
WorkPullingProducerController.MessageWithConfirmation<A>	For sending confirmation message back to the producer when the message has been fully delivered, processed, and confirmed by the consumer.
WorkPullingProducerController.MessageWithConfirmation$
WorkPullingProducerController.RequestNext<A>	The WorkPullingProducerController sends RequestNext to the producer when it is allowed to send one message via the sendNextTo or askNextTo.
WorkPullingProducerController.RequestNext$
WorkPullingProducerController.Settings
WorkPullingProducerController.Settings$
WorkPullingProducerController.Start<A>	Initial message from the producer actor.
WorkPullingProducerController.Start$
WorkPullingProducerController.WorkerStats
WorkPullingProducerController.WorkerStats$
WorkPullingProducerController$	Work pulling is a pattern where several worker actors pull tasks in their own pace from a shared work manager instead of that the manager pushes work to the workers blindly without knowing their individual capacity and current availability.