trait AtMostOnceProjection[Offset, Envelope] extends Projection[Envelope]
- Self Type
- AtMostOnceProjection[Offset, Envelope] with InternalProjection
- Annotations
- @DoNotInherit()
- Source
- Projections.scala
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- AtMostOnceProjection
- Projection
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Abstract Value Members
- abstract def projectionId: ProjectionId
- Definition Classes
- Projection
- abstract def statusObserver: StatusObserver[Envelope]
- Definition Classes
- Projection
- abstract def withRecoveryStrategy(recoveryStrategy: StrictRecoveryStrategy): AtMostOnceProjection[Offset, Envelope]
- abstract def withRestartBackoff(minBackoff: Duration, maxBackoff: Duration, randomFactor: Double, maxRestarts: Int): AtMostOnceProjection[Offset, Envelope]
Java API
Java API
- Definition Classes
- AtMostOnceProjection → Projection
- abstract def withRestartBackoff(minBackoff: Duration, maxBackoff: Duration, randomFactor: Double): AtMostOnceProjection[Offset, Envelope]
Java API
Java API
- Definition Classes
- AtMostOnceProjection → Projection
- abstract def withRestartBackoff(minBackoff: FiniteDuration, maxBackoff: FiniteDuration, randomFactor: Double, maxRestarts: Int): Projection[Envelope]
- Definition Classes
- Projection
- abstract def withRestartBackoff(minBackoff: FiniteDuration, maxBackoff: FiniteDuration, randomFactor: Double): Projection[Envelope]
- Definition Classes
- Projection
- abstract def withStatusObserver(observer: StatusObserver[Envelope]): AtMostOnceProjection[Offset, Envelope]
- Definition Classes
- AtMostOnceProjection → Projection