Packages

c

org.apache.pekko.projection

StatusObserver

abstract class StatusObserver[-Envelope] extends AnyRef

Track status of a projection by implementing a StatusObserver and install it using Projection.withStatusObserver.

Annotations
@ApiMayChange()
Source
StatusObserver.scala
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. StatusObserver
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new StatusObserver()

Abstract Value Members

  1. abstract def afterProcess(projectionId: ProjectionId, envelope: Envelope): Unit

    Invoked as soon as the projected information is readable by a separate thread (e.g committed to database).

    Invoked as soon as the projected information is readable by a separate thread (e.g committed to database). It will not be invoked if the envelope is skipped or handling fails.

  2. abstract def beforeProcess(projectionId: ProjectionId, envelope: Envelope): Unit

    Called as soon as an envelop is ready to be processed.

    Called as soon as an envelop is ready to be processed. The envelope processing may not start immediately if grouping or batching are enabled.

  3. abstract def error(projectionId: ProjectionId, env: Envelope, cause: Throwable, recoveryStrategy: HandlerRecoveryStrategy): Unit

    Called when processing of an envelope failed.

    Called when processing of an envelope failed. The invocation of this method is not guaranteed when the handler failure causes a stream failure (e.g. using a Flow-based handler or a recovery strategy that immediately fails).

    From the recoveryStrategy and keeping track how many times error is called it's possible to derive what next step will be; fail, skip, retry.

  4. abstract def failed(projectionId: ProjectionId, cause: Throwable): Unit

    Called when a projection failed.

    Called when a projection failed.

    The projection will be restarted unless the projection restart backoff settings are configured with max-restarts limit.

  5. abstract def offsetProgress(projectionId: ProjectionId, env: Envelope): Unit

    Called when the corresponding offset has been stored.

    Called when the corresponding offset has been stored. It might not be called for each envelope.

  6. abstract def started(projectionId: ProjectionId): Unit

    Called when a projection is started.

    Called when a projection is started. Also called after the projection has been restarted.

  7. abstract def stopped(projectionId: ProjectionId): Unit

    Called when a projection is stopped.

    Called when a projection is stopped. Also called before the projection is restarted.

Concrete Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native()
  6. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  7. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  8. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable])
  9. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  10. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  11. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  12. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  13. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  14. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  15. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  16. def toString(): String
    Definition Classes
    AnyRef → Any
  17. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  18. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  19. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()

Inherited from AnyRef

Inherited from Any

Ungrouped