t

akka.projection.javadsl

AtLeastOnceProjection

trait AtLeastOnceProjection[Offset, Envelope] extends Projection[Envelope]

Self Type
AtLeastOnceProjection[Offset, Envelope] with InternalProjection
Annotations
@DoNotInherit()
Source
Projections.scala
Linear Supertypes
Projection[Envelope], AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. AtLeastOnceProjection
  2. Projection
  3. AnyRef
  4. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Abstract Value Members

  1. abstract def projectionId: ProjectionId
    Definition Classes
    Projection
  2. abstract def statusObserver: StatusObserver[Envelope]
    Definition Classes
    Projection
  3. abstract def withRecoveryStrategy(recoveryStrategy: HandlerRecoveryStrategy): AtLeastOnceProjection[Offset, Envelope]
  4. abstract def withRestartBackoff(minBackoff: Duration, maxBackoff: Duration, randomFactor: Double, maxRestarts: Int): AtLeastOnceProjection[Offset, Envelope]

    Java API

    Java API

    Definition Classes
    AtLeastOnceProjection → Projection
  5. abstract def withRestartBackoff(minBackoff: Duration, maxBackoff: Duration, randomFactor: Double): AtLeastOnceProjection[Offset, Envelope]

    Java API

    Java API

    Definition Classes
    AtLeastOnceProjection → Projection
  6. abstract def withRestartBackoff(minBackoff: FiniteDuration, maxBackoff: FiniteDuration, randomFactor: Double, maxRestarts: Int): Projection[Envelope]
    Definition Classes
    Projection
  7. abstract def withRestartBackoff(minBackoff: FiniteDuration, maxBackoff: FiniteDuration, randomFactor: Double): Projection[Envelope]
    Definition Classes
    Projection
  8. abstract def withSaveOffset(afterEnvelopes: Int, afterDuration: Duration): AtLeastOnceProjection[Offset, Envelope]
  9. abstract def withStatusObserver(observer: StatusObserver[Envelope]): AtLeastOnceProjection[Offset, Envelope]
    Definition Classes
    AtLeastOnceProjection → Projection