raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 11

+ akka-persistence: add internal message protocol traits

Browse source 
2 more snapshot messages used for internal plugin acknowledgement in
https://github.com/akka/akka/blob/master/akka-persistence/src/main/scala/akka/persistence/snapshot/SnapshotStore.scala
* see #16612 
* see #16633
This commit is contained in:
Andrei Pozolotin 2015-01-23 09:17:34 -06:00
parent 4437f775e5
commit 98ac9f7020
1 changed files with 2 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-persistence/src/main/scala/akka/persistence/SnapshotProtocol.scala
View file

@ -24,6 +24,7 @@ final case class SnapshotMetadata(persistenceId: String, sequenceNr: Long, times
*/ */
@SerialVersionUID(1L) @SerialVersionUID(1L)
final case class SaveSnapshotSuccess(metadata: SnapshotMetadata) final case class SaveSnapshotSuccess(metadata: SnapshotMetadata)
extends SnapshotProtocol.Response
/** /**
* Sent to a [[PersistentActor]] after failed saving of a snapshot. * Sent to a [[PersistentActor]] after failed saving of a snapshot.
@ -33,6 +34,7 @@ final case class SaveSnapshotSuccess(metadata: SnapshotMetadata)
*/ */
@SerialVersionUID(1L) @SerialVersionUID(1L)
final case class SaveSnapshotFailure(metadata: SnapshotMetadata, cause: Throwable) final case class SaveSnapshotFailure(metadata: SnapshotMetadata, cause: Throwable)
extends SnapshotProtocol.Response
/** /**
* Offers a [[PersistentActor]] a previously saved `snapshot` during recovery. This offer is received * Offers a [[PersistentActor]] a previously saved `snapshot` during recovery. This offer is received