abstract class ActorHandler[Envelope, T] extends Handler[Envelope] with ActorHandlerInit[T]

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.

Source
ActorHandler.scala
Linear Supertypes
ActorHandlerInit[T], Handler[Envelope], HandlerLifecycle, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ActorHandler
  2. ActorHandlerInit
  3. Handler
  4. HandlerLifecycle
  5. AnyRef
  6. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new ActorHandler(behavior: Behavior[T])

Abstract Value Members

  1. abstract def process(actor: ActorRef[T], envelope: Envelope): Future[Done]

    The process method is invoked for each Envelope.

    The process method is invoked for each Envelope. One envelope is processed at a time. The returned Future is to be completed when the processing of the envelope has finished. It will not be invoked with the next envelope until after the returned Future has been completed.

    The behavior is spawned when the Projection is started and the ActorRef is passed in as a parameter here.

    You will typically use the AskPattern.ask to delegate the processing of the envelope to the actor and the returned Future corresponds to the reply of the ask.

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. val behavior: Behavior[T]

    INTERNAL API

    INTERNAL API

    Definition Classes
    ActorHandler → ActorHandlerInit
  6. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
  7. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  8. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  9. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @IntrinsicCandidate() @native()
  10. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @IntrinsicCandidate() @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
    @IntrinsicCandidate() @native()
  14. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @IntrinsicCandidate() @native()
  15. final def process(envelope: Envelope): Future[Done]

    The process method is invoked for each Envelope.

    The process method is invoked for each Envelope. One envelope is processed at a time. The returned Future is to be completed when the processing of the envelope has finished. It will not be invoked with the next envelope until after the returned Future has been completed.

    Definition Classes
    ActorHandler → Handler
  16. def start(): Future[Done]

    Invoked when the projection is starting, before first envelope is processed.

    Invoked when the projection is starting, before first envelope is processed. Can be overridden to implement initialization. It is also called when the Projection is restarted after a failure.

    Definition Classes
    HandlerLifecycle
  17. def stop(): Future[Done]

    Invoked when the projection has been stopped.

    Invoked when the projection has been stopped. Can be overridden to implement resource cleanup. It is also called when the Projection is restarted after a failure.

    Definition Classes
    HandlerLifecycle
  18. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  19. def toString(): String
    Definition Classes
    AnyRef → Any
  20. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  21. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  22. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable]) @Deprecated
    Deprecated

    (Since version 9)

Inherited from ActorHandlerInit[T]

Inherited from Handler[Envelope]

Inherited from HandlerLifecycle

Inherited from AnyRef

Inherited from Any

Ungrouped