package akka
Lerna Utililities for Akka
Overview
The package provides utilities for Akka (especially Akka classic)
- AtLeastOnceDelivery$ Reliable delivery for Akka classic
- ActorStateBase The trait for defining an event sourcing actor state
- ProcessingTimeout The class for handling timeout
- stream.FailureSkipFlow The Akka Stream Flow for both skipping and handling failures
- Alphabetic
- By Inheritance
- akka
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Type Members
-
trait
ActorStateBase[Event, State <: ActorStateBase[Event, State]] extends AnyRef
A trait that represents a base actor state for event sourcing
A trait that represents a base actor state for event sourcing
The trait is for a classic actor (not typed). You don't need any more if you use a typed actor.
- Event
The type of Event that is handled by the actor
- State
The type of State of the actor
-
sealed abstract
case class
ProcessingTimeout extends NoSerializationVerificationNeeded with Product with Serializable
A class that represents processing timeout
A class that represents processing timeout
The
deadlineis required to distinguish each ProcessingTimeout since the timer is invoked after actor restart flow (specifically receiveRecover -> updateState) -
final
case class
ReplyTo(actorRef: ActorRef) extends AnyVal with Product with Serializable
A class that represents a reply destination akka.actor.ActorRef
A class that represents a reply destination akka.actor.ActorRef
- actorRef
The reply destination actor
Value Members
-
object
AtLeastOnceDelivery
An object that provides reliable delivery features
-
object
ProcessingTimeout extends Serializable
An object that provides factory methods of ProcessingTimeout