UntypedPersistentView

abstract def onReceive(message: Any): Unit

To be implemented by concrete UntypedActor, this defines the behavior of the UntypedActor.

abstract def persistenceId: String

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

abstract def viewId: String

View id is used as identifier for snapshots performed by this PersistentView.

class SummingView extends PersistentView {
  override def persistenceId = "count-123"
  override def viewId        = "count-123-sum" // this view is performing summing,
                                               // so this view's snapshots reside under the "-sum" suffixed id

  // ...
}

final def !=(arg0: Any): Boolean

final def ##(): Int

def +(other: String): String

def ->[B](y: B): (UntypedPersistentView, B)

final def ==(arg0: Any): Boolean

def aroundPostRestart(reason: Throwable): Unit

Can be overridden to intercept calls to postRestart.

def aroundPostStop(): Unit

Can be overridden to intercept calls to postStop.

def aroundPreRestart(reason: Throwable, message: Option[Any]): Unit

Can be overridden to intercept calls to preRestart.

def aroundPreStart(): Unit

INTERNAL API.

def aroundReceive(receive: Receive, message: Any): Unit

INTERNAL API.

final def asInstanceOf[T0]: T0

def autoUpdate: Boolean

If true, this view automatically updates itself with an interval specified by autoUpdateInterval.

def autoUpdateInterval: FiniteDuration

The interval for automated updates.

def autoUpdateReplayMax: Long

The maximum number of messages to replay per update.

def clone(): AnyRef

implicit val context: ActorContext

Stores the context for this actor, including self, and sender.

def deleteSnapshot(sequenceNr: Long, timestamp: Long): Unit

Deletes a snapshot identified by sequenceNr and timestamp.

def deleteSnapshots(criteria: SnapshotSelectionCriteria): Unit

Deletes all snapshots matching criteria.

def ensuring(cond: (UntypedPersistentView) ⇒ Boolean, msg: ⇒ Any): UntypedPersistentView

def ensuring(cond: (UntypedPersistentView) ⇒ Boolean): UntypedPersistentView

def ensuring(cond: Boolean, msg: ⇒ Any): UntypedPersistentView

def ensuring(cond: Boolean): UntypedPersistentView

final def eq(arg0: AnyRef): Boolean

def equals(arg0: Any): Boolean

def finalize(): Unit

def formatted(fmtstr: String): String

final def getClass(): Class[_]

def getContext(): UntypedActorContext

Returns this UntypedActor's UntypedActorContext The UntypedActorContext is not thread safe so do not expose it outside of the UntypedActor.

def getSelf(): ActorRef

Returns the ActorRef for this actor.

def getSender(): ActorRef

The reference sender Actor of the currently processed message.

def hashCode(): Int

final def isInstanceOf[T0]: Boolean

def isPersistent: Boolean

If true, the currently processed message was persisted (is sent from the Journal).

def journalPluginId: String

Configuration id of the journal plugin servicing this persistent actor or view.

def lastSequenceNr: Long

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

def loadSnapshot(persistenceId: String, criteria: SnapshotSelectionCriteria, toSequenceNr: Long): Unit

final def ne(arg0: AnyRef): Boolean

final def notify(): Unit

final def notifyAll(): Unit

def postRestart(reason: Throwable): Unit

User overridable callback: By default it calls preStart().

def postStop(): Unit

Overridden callback.

def preRestart(reason: Throwable, message: Option[Any]): Unit

Overridden callback.

def preStart(): Unit

Triggers an initial recovery, starting form a snapshot, if any, and replaying at most autoUpdateReplayMax messages (following that snapshot).

final def receive: PartialFunction[Any, Unit]

This defines the initial actor behavior, it must return a partial function with the actor logic.

def saveSnapshot(snapshot: Any): Unit

Saves a snapshot of this snapshotter's state.

implicit final val self: ActorRef

The 'self' field holds the ActorRef for this actor.

self ! message

final def sender(): ActorRef

The reference sender Actor of the last received message.

def snapshotPluginId: String

Configuration id of the snapshot plugin servicing this persistent actor or view.

def snapshotSequenceNr: Long

Returns lastSequenceNr.

def snapshotterId: String

Returns viewId.

def stash(): Unit

Adds the current message (the message that the actor received last) to the actor's stash.

def supervisorStrategy: SupervisorStrategy

User overridable definition the strategy to use for supervising child actors.

final def synchronized[T0](arg0: ⇒ T0): T0

def toString(): String

def unhandled(message: Any): Unit

User overridable callback.

def unstashAll(): Unit

Prepends all messages in the stash to the mailbox, and then clears the stash.

final def wait(): Unit

final def wait(arg0: Long, arg1: Int): Unit

final def wait(arg0: Long): Unit

def →[B](y: B): (UntypedPersistentView, B)