Type Members

1.  abstract class ActorHandler[Envelope, T] extends Handler[Envelope]

   This Handler gives support for spawning an actor of a given Behavior to delegate processing of the envelopes to the actor.

   This Handler gives support for spawning an actor of a given Behavior to delegate processing of the envelopes to the actor.

   The lifecycle of the actor is managed by the Projection. The behavior is spawned when the Projection is started and the ActorRef is passed in as a parameter to the process method. The Actor is stopped when the Projection is stopped.

2.  trait AtLeastOnceFlowProjection[Offset, Envelope] extends Projection[Envelope]

   Annotations

   @DoNotInherit()

3.  trait AtLeastOnceProjection[Offset, Envelope] extends Projection[Envelope]

   Annotations

   @DoNotInherit()

4.  trait AtMostOnceProjection[Offset, Envelope] extends Projection[Envelope]

   Annotations

   @DoNotInherit()

5.  trait ExactlyOnceProjection[Offset, Envelope] extends Projection[Envelope]

   Annotations

   @DoNotInherit()

6.  trait GroupedProjection[Offset, Envelope] extends Projection[Envelope]

   Annotations

   @DoNotInherit()

7.  abstract class Handler[Envelope] extends HandlerLifecycle

   Implement this interface for the Envelope handler in the Projection.

   Implement this interface for the Envelope handler in the Projection. Some projections may have more specific handler types.

   It can be stateful, with variables and mutable data structures. It is invoked by the Projection machinery one envelope at a time and visibility guarantees between the invocations are handled automatically, i.e. no volatile or other concurrency primitives are needed for managing the state.

   Supported error handling strategies for when processing an Envelope fails can be defined in configuration or using the withRecoveryStrategy method of a Projection implementation.

8.  trait HandlerLifecycle extends AnyRef
9.  trait MergeableOffsetSourceProvider[Offset <: MergeableOffset[_], Envelope] extends SourceProvider[Offset, Envelope]
10.  class ProjectionManagement extends AnyRef
11.  abstract class SourceProvider[Offset, Envelope] extends AnyRef
12.  abstract class StatefulHandler[State, Envelope] extends Handler[Envelope]
13.  trait VerifiableSourceProvider[Offset, Envelope] extends SourceProvider[Offset, Envelope]