Class EventSourcedProducerQueue

A DurableProducerQueue implementation that can be used with ProducerController for reliable delivery of messages. It is implemented with event-sourcing and stores one event before sending the message to the destination and one event for the confirmation that the message has been delivered and processed.

Inheritance

object

EventSourcedProducerQueue

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Namespace: Akka.Persistence.Delivery

Assembly: Akka.Persistence.dll

Syntax

public static class EventSourcedProducerQueue

Methods

| Edit this page View Source

Create<T>(string, IActorRefFactory)

Creates Props for an Akka.Persistence.Delivery.EventSourcedProducerQueue<T> that can be passed to a ProducerController for reliable message delivery.

Declaration

public static Props Create<T>(string persistentId, IActorRefFactory system)

Parameters

Type	Name	Description
string	persistentId	The Akka.Persistence id used by this actor - must be globally unique.
IActorRefFactory	system	The ActorSystem or IActorContext this actor might be created under. This value is only used to load the EventSourcedProducerQueue.Settings.

Returns

Type	Description
Props

Type Parameters

Name	Description
T	The type of message that is supported by the ProducerController.