t

akka.persistence

AtLeastOnceDeliveryLike

trait AtLeastOnceDeliveryLike extends Eventsourced

Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. AtLeastOnceDeliveryLike
  2. Eventsourced
  3. PersistenceRecovery
  4. PersistenceIdentity
  5. PersistenceStash
  6. StashFactory
  7. Stash
  8. RequiresMessageQueue
  9. UnrestrictedStash
  10. StashSupport
  11. Snapshotter
  12. Actor
  13. AnyRef
  14. Any
Implicitly
  1. by any2stringadd
  2. by StringFormat
  3. by Ensuring
  4. by ArrowAssoc
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Type Members

  1. type Receive = PartialFunction[Any, Unit]
    Definition Classes
    Actor

Abstract Value Members

  1. abstract def persistenceId: String

    Id of the persistent entity for which messages should be replayed.

    Id of the persistent entity for which messages should be replayed.

    Definition Classes
    PersistenceIdentity
  2. abstract def receive: actor.Actor.Receive
    Definition Classes
    Actor
  3. abstract def receiveCommand: Receive

    Command handler.

    Command handler. Typically validates commands against current state (and/or by communication with other actors). On successful validation, one or more events are derived from a command and these events are then persisted by calling persist.

    Definition Classes
    Eventsourced
  4. abstract def receiveRecover: Receive

    Recovery handler that receives persisted events during recovery.

    Recovery handler that receives persisted events during recovery. If a state snapshot has been captured and saved, this handler will receive a SnapshotOffer message followed by events that are younger than the offered snapshot.

    This handler must not have side-effects other than changing persistent actor state i.e. it should not perform actions that may fail, such as interacting with external services, for example.

    If there is a problem with recovering the state of the actor from the journal, the error will be logged and the actor will be stopped.

    Definition Classes
    Eventsourced
    See also

    Recovery

Concrete Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int
    Definition Classes
    AnyRef → Any
  3. def +(other: String): String
    Implicit
    This member is added by an implicit conversion from AtLeastOnceDeliveryLike to any2stringadd[AtLeastOnceDeliveryLike] performed by method any2stringadd in scala.Predef.
    Definition Classes
    any2stringadd
  4. def ->[B](y: B): (AtLeastOnceDeliveryLike, B)
    Implicit
    This member is added by an implicit conversion from AtLeastOnceDeliveryLike to ArrowAssoc[AtLeastOnceDeliveryLike] performed by method ArrowAssoc in scala.Predef.
    Definition Classes
    ArrowAssoc
    Annotations
    @inline()
  5. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  6. def aroundPostRestart(reason: Throwable): Unit

    INTERNAL API.

    INTERNAL API.

    Attributes
    protected[akka]
    Definition Classes
    Eventsourced → Actor
  7. def aroundPostStop(): Unit

    INTERNAL API

    INTERNAL API

    Attributes
    protected[akka]
    Definition Classes
    AtLeastOnceDeliveryLike → Eventsourced → Actor
  8. def aroundPreRestart(reason: Throwable, message: Option[Any]): Unit

    INTERNAL API

    INTERNAL API

    Attributes
    protected[akka]
    Definition Classes
    AtLeastOnceDeliveryLike → Eventsourced → Actor
  9. def aroundPreStart(): Unit

    INTERNAL API.

    INTERNAL API.

    Attributes
    protected[akka]
    Definition Classes
    Eventsourced → Actor
  10. def aroundReceive(receive: Receive, message: Any): Unit

    INTERNAL API

    INTERNAL API

    Attributes
    protected[akka]
    Definition Classes
    AtLeastOnceDeliveryLike → Eventsourced → Actor
  11. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  12. def clone(): AnyRef
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate() @throws( ... )
  13. def confirmDelivery(deliveryId: Long): Boolean

    Call this method when a message has been confirmed by the destination, or to abort re-sending.

    Call this method when a message has been confirmed by the destination, or to abort re-sending.

    returns

    true the first time the deliveryId is confirmed, i.e. false for duplicate confirm

    See also

    #deliver

  14. implicit val context: ActorContext
    Definition Classes
    Actor
  15. def deleteMessages(toSequenceNr: Long): Unit

    Permanently deletes all persistent messages with sequence numbers less than or equal toSequenceNr.

    Permanently deletes all persistent messages with sequence numbers less than or equal toSequenceNr.

    If the delete is successful a DeleteMessagesSuccess will be sent to the actor. If the delete fails a DeleteMessagesFailure will be sent to the actor.

    The given toSequenceNr must be less than or equal to Eventsourced#lastSequenceNr, otherwise DeleteMessagesFailure is sent to the actor without performing the delete. All persistent messages may be deleted without specifying the actual sequence number by using Long.MaxValue as the toSequenceNr.

    toSequenceNr

    upper sequence number (inclusive) bound of persistent messages to be deleted.

    Definition Classes
    Eventsourced
  16. def deleteSnapshot(sequenceNr: Long): Unit

    Deletes the snapshot identified by sequenceNr.

    Deletes the snapshot identified by sequenceNr.

    The PersistentActor will be notified about the status of the deletion via an DeleteSnapshotSuccess or DeleteSnapshotFailure message.

    Definition Classes
    Snapshotter
  17. def deleteSnapshots(criteria: SnapshotSelectionCriteria): Unit

    Deletes all snapshots matching criteria.

    Deletes all snapshots matching criteria.

    The PersistentActor will be notified about the status of the deletion via an DeleteSnapshotsSuccess or DeleteSnapshotsFailure message.

    Definition Classes
    Snapshotter
  18. def ensuring(cond: (AtLeastOnceDeliveryLike) ⇒ Boolean, msg: ⇒ Any): AtLeastOnceDeliveryLike
    Implicit
    This member is added by an implicit conversion from AtLeastOnceDeliveryLike to Ensuring[AtLeastOnceDeliveryLike] performed by method Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  19. def ensuring(cond: (AtLeastOnceDeliveryLike) ⇒ Boolean): AtLeastOnceDeliveryLike
    Implicit
    This member is added by an implicit conversion from AtLeastOnceDeliveryLike to Ensuring[AtLeastOnceDeliveryLike] performed by method Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  20. def ensuring(cond: Boolean, msg: ⇒ Any): AtLeastOnceDeliveryLike
    Implicit
    This member is added by an implicit conversion from AtLeastOnceDeliveryLike to Ensuring[AtLeastOnceDeliveryLike] performed by method Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  21. def ensuring(cond: Boolean): AtLeastOnceDeliveryLike
    Implicit
    This member is added by an implicit conversion from AtLeastOnceDeliveryLike to Ensuring[AtLeastOnceDeliveryLike] performed by method Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  22. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  23. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  24. def formatted(fmtstr: String): String
    Implicit
    This member is added by an implicit conversion from AtLeastOnceDeliveryLike to StringFormat[AtLeastOnceDeliveryLike] performed by method StringFormat in scala.Predef.
    Definition Classes
    StringFormat
    Annotations
    @inline()
  25. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  26. def getDeliverySnapshot: AtLeastOnceDeliverySnapshot

    Full state of the AtLeastOnceDelivery.

    Full state of the AtLeastOnceDelivery. It can be saved with PersistentActor#saveSnapshot. During recovery the snapshot received in SnapshotOffer should be set with #setDeliverySnapshot.

    The AtLeastOnceDeliverySnapshot contains the full delivery state, including unconfirmed messages. If you need a custom snapshot for other parts of the actor state you must also include the AtLeastOnceDeliverySnapshot. It is serialized using protobuf with the ordinary Akka serialization mechanism. It is easiest to include the bytes of the AtLeastOnceDeliverySnapshot as a blob in your custom snapshot.

  27. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  28. def internalStashOverflowStrategy: StashOverflowStrategy

    The returned StashOverflowStrategy object determines how to handle the message failed to stash when the internal Stash capacity exceeded.

    The returned StashOverflowStrategy object determines how to handle the message failed to stash when the internal Stash capacity exceeded.

    Definition Classes
    PersistenceStash
  29. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  30. def journalPluginId: String

    Configuration id of the journal plugin servicing this persistent actor.

    Configuration id of the journal plugin servicing this persistent actor. When empty, looks in akka.persistence.journal.plugin to find configuration entry path. When configured, uses journalPluginId as absolute path to the journal configuration entry. Configuration entry must contain few required fields, such as class. See src/main/resources/reference.conf.

    Definition Classes
    PersistenceIdentity
  31. def lastSequenceNr: Long

    Highest received sequence number so far or 0L if this actor hasn't replayed or stored any persistent events yet.

    Highest received sequence number so far or 0L if this actor hasn't replayed or stored any persistent events yet.

    Definition Classes
    Eventsourced
  32. def loadSnapshot(persistenceId: String, criteria: SnapshotSelectionCriteria, toSequenceNr: Long): Unit

    Instructs the snapshot store to load the specified snapshot and send it via an SnapshotOffer to the running PersistentActor.

    Instructs the snapshot store to load the specified snapshot and send it via an SnapshotOffer to the running PersistentActor.

    Definition Classes
    Snapshotter
  33. def maxUnconfirmedMessages: Int

    Maximum number of unconfirmed messages that this actor is allowed to hold in memory.

    Maximum number of unconfirmed messages that this actor is allowed to hold in memory. If this number is exceed #deliver will not accept more messages and it will throw AtLeastOnceDelivery.MaxUnconfirmedMessagesExceededException.

    The default value can be configured with the akka.persistence.at-least-once-delivery.max-unconfirmed-messages configuration key. This method can be overridden by implementation classes to return non-default values.

  34. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  35. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  36. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  37. def numberOfUnconfirmed: Int

    Number of messages that have not been confirmed yet.

  38. def onPersistFailure(cause: Throwable, event: Any, seqNr: Long): Unit

    Called when persist fails.

    Called when persist fails. By default it logs the error. Subclass may override to customize logging and for example send negative acknowledgment to sender.

    The actor is always stopped after this method has been invoked.

    Note that the event may or may not have been saved, depending on the type of failure.

    cause

    failure cause.

    event

    the event that was to be persisted

    Attributes
    protected
    Definition Classes
    Eventsourced
    Annotations
    @InternalStableApi()
  39. def onPersistRejected(cause: Throwable, event: Any, seqNr: Long): Unit

    Called when the journal rejected persist of an event.

    Called when the journal rejected persist of an event. The event was not stored. By default this method logs the problem as an error, and the actor continues. The callback handler that was passed to the persist method will not be invoked.

    cause

    failure cause

    event

    the event that was to be persisted

    Attributes
    protected
    Definition Classes
    Eventsourced
    Annotations
    @InternalStableApi()
  40. def onRecoveryFailure(cause: Throwable, event: Option[Any]): Unit

    Called whenever a message replay fails.

    Called whenever a message replay fails. By default it logs the error.

    Subclass may override to customize logging.

    The actor is always stopped after this method has been invoked.

    cause

    failure cause.

    event

    the event that was processed in receiveRecover, if the exception was thrown there

    Attributes
    protected
    Definition Classes
    Eventsourced
    Annotations
    @InternalStableApi()
  41. def postRestart(reason: Throwable): Unit
    Definition Classes
    Actor
    Annotations
    @throws( classOf[java.lang.Exception] )
  42. def postStop(): Unit
    Definition Classes
    UnrestrictedStash → Actor
    Annotations
    @throws( classOf[java.lang.Exception] )
  43. def preRestart(reason: Throwable, message: Option[Any]): Unit
    Definition Classes
    UnrestrictedStash → Actor
    Annotations
    @throws( classOf[java.lang.Exception] )
  44. def preStart(): Unit
    Definition Classes
    Actor
    Annotations
    @throws( classOf[java.lang.Exception] )
  45. def recovery: Recovery

    Called when the persistent actor is started for the first time.

    Called when the persistent actor is started for the first time. The returned Recovery object defines how the Actor will recover its persistent state before handling the first incoming message.

    To skip recovery completely return Recovery.none.

    Definition Classes
    PersistenceRecovery
  46. def recoveryFinished: Boolean

    Returns true if this persistent actor has successfully finished recovery.

    Returns true if this persistent actor has successfully finished recovery.

    Definition Classes
    Eventsourced
  47. def recoveryRunning: Boolean

    Returns true if this persistent actor is currently recovering.

    Returns true if this persistent actor is currently recovering.

    Definition Classes
    Eventsourced
  48. def redeliverInterval: FiniteDuration

    Interval between redelivery attempts.

    Interval between redelivery attempts.

    The default value can be configured with the akka.persistence.at-least-once-delivery.redeliver-interval configuration key. This method can be overridden by implementation classes to return non-default values.

  49. def redeliveryBurstLimit: Int

    Maximum number of unconfirmed messages that will be sent at each redelivery burst (burst frequency is half of the redelivery interval).

    Maximum number of unconfirmed messages that will be sent at each redelivery burst (burst frequency is half of the redelivery interval). If there's a lot of unconfirmed messages (e.g. if the destination is not available for a long time), this helps to prevent an overwhelming amount of messages to be sent at once.

    The default value can be configured with the akka.persistence.at-least-once-delivery.redelivery-burst-limit configuration key. This method can be overridden by implementation classes to return non-default values.

  50. def saveSnapshot(snapshot: Any): Unit

    Saves a snapshot of this snapshotter's state.

    Saves a snapshot of this snapshotter's state.

    The PersistentActor will be notified about the success or failure of this via an SaveSnapshotSuccess or SaveSnapshotFailure message.

    Definition Classes
    Snapshotter
  51. implicit final val self: ActorRef
    Definition Classes
    Actor
  52. final def sender(): ActorRef
    Definition Classes
    Actor
  53. def setDeliverySnapshot(snapshot: AtLeastOnceDeliverySnapshot): Unit

    If snapshot from #getDeliverySnapshot was saved it will be received during recovery in a SnapshotOffer message and should be set with this method.

  54. def snapshotPluginId: String

    Configuration id of the snapshot plugin servicing this persistent actor.

    Configuration id of the snapshot plugin servicing this persistent actor. When empty, looks in akka.persistence.snapshot-store.plugin to find configuration entry path. When configured, uses snapshotPluginId as absolute path to the snapshot store configuration entry. Configuration entry must contain few required fields, such as class. See src/main/resources/reference.conf.

    Definition Classes
    PersistenceIdentity
  55. def snapshotSequenceNr: Long

    Returns lastSequenceNr.

    Returns lastSequenceNr.

    Definition Classes
    Eventsourced → Snapshotter
  56. def snapshotterId: String

    Returns persistenceId.

    Returns persistenceId.

    Definition Classes
    Eventsourced → Snapshotter
  57. def stash(): Unit
    Definition Classes
    Eventsourced → StashSupport
  58. def supervisorStrategy: SupervisorStrategy
    Definition Classes
    Actor
  59. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  60. def toString(): String
    Definition Classes
    AnyRef → Any
  61. def unhandled(message: Any): Unit
    Definition Classes
    Eventsourced → Actor
  62. def unstashAll(): Unit
    Definition Classes
    Eventsourced → StashSupport
  63. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  64. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )
  65. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  66. def warnAfterNumberOfUnconfirmedAttempts: Int

    After this number of delivery attempts an AtLeastOnceDelivery.UnconfirmedWarning message will be sent to self.

    After this number of delivery attempts an AtLeastOnceDelivery.UnconfirmedWarning message will be sent to self. The count is reset after a restart.

    The default value can be configured with the akka.persistence.at-least-once-delivery.warn-after-number-of-unconfirmed-attempts configuration key. This method can be overridden by implementation classes to return non-default values.

  67. def [B](y: B): (AtLeastOnceDeliveryLike, B)
    Implicit
    This member is added by an implicit conversion from AtLeastOnceDeliveryLike to ArrowAssoc[AtLeastOnceDeliveryLike] performed by method ArrowAssoc in scala.Predef.
    Definition Classes
    ArrowAssoc

Deprecated Value Members

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

    (Since version ) see corresponding Javadoc for more information.

Inherited from Eventsourced

Inherited from PersistenceRecovery

Inherited from PersistenceIdentity

Inherited from PersistenceStash

Inherited from StashFactory

Inherited from Stash

Inherited from RequiresMessageQueue[DequeBasedMessageQueueSemantics]

Inherited from UnrestrictedStash

Inherited from StashSupport

Inherited from Snapshotter

Inherited from Actor

Inherited from AnyRef

Inherited from Any

Inherited by implicit conversion any2stringadd from AtLeastOnceDeliveryLike to any2stringadd[AtLeastOnceDeliveryLike]

Inherited by implicit conversion StringFormat from AtLeastOnceDeliveryLike to StringFormat[AtLeastOnceDeliveryLike]

Inherited by implicit conversion Ensuring from AtLeastOnceDeliveryLike to Ensuring[AtLeastOnceDeliveryLike]

Inherited by implicit conversion ArrowAssoc from AtLeastOnceDeliveryLike to ArrowAssoc[AtLeastOnceDeliveryLike]

Ungrouped