| ConsumerController |
|
| 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$ |
|
| DurableProducerQueue |
Actor message protocol for storing and confirming reliable delivery of messages.
|
| DurableProducerQueue.Cleanup$ |
|
| DurableProducerQueue.Confirmed$ |
|
| 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.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.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.
|