t

akka.projection.javadsl

AtMostOnceProjection

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

Self Type
AtMostOnceProjection[Offset, Envelope] with InternalProjection
Annotations
@DoNotInherit()
Source
Projections.scala
Linear Supertypes
Projection[Envelope], AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. AtMostOnceProjection
  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: StrictRecoveryStrategy): AtMostOnceProjection[Offset, Envelope]
  4. abstract def withRestartBackoff(minBackoff: Duration, maxBackoff: Duration, randomFactor: Double, maxRestarts: Int): AtMostOnceProjection[Offset, Envelope]

    Java API

    Java API

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

    Java API

    Java API

    Definition Classes
    AtMostOnceProjectionProjection
  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 withStatusObserver(observer: StatusObserver[Envelope]): AtMostOnceProjection[Offset, Envelope]
    Definition Classes
    AtMostOnceProjectionProjection