You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pekko.apache.org by fa...@apache.org on 2026/05/15 07:37:17 UTC
(pekko) branch main updated: fix javadoc durable state deleteobject (#2972)
This is an automated email from the ASF dual-hosted git repository.
pjfanning pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pekko.git
The following commit(s) were added to refs/heads/main by this push:
new 83b1b31604 fix javadoc durable state deleteobject (#2972)
83b1b31604 is described below
commit 83b1b316049e303dbb4a44a65c032bf503b4f7cb
Author: PJ Fanning <pj...@users.noreply.github.com>
AuthorDate: Fri May 15 08:37:12 2026 +0100
fix javadoc durable state deleteobject (#2972)
* fix: clarify deleteObject revision must be expected next revision (current + 1) in docs
Agent-Logs-Url: https://github.com/pjfanning/incubator-pekko/sessions/e855d7d3-4827-4438-9c9d-8f288f2f0c4d
Co-authored-by: pjfanning <11...@users.noreply.github.com>
* further changes
---------
Co-authored-by: copilot-swe-agent[bot] <19...@users.noreply.github.com>
Co-authored-by: pjfanning <11...@users.noreply.github.com>
---
.../pekko/persistence/state/javadsl/DurableStateUpdateStore.scala | 7 ++++---
.../pekko/persistence/state/scaladsl/DurableStateUpdateStore.scala | 7 ++++---
2 files changed, 8 insertions(+), 6 deletions(-)
diff --git a/persistence/src/main/scala/org/apache/pekko/persistence/state/javadsl/DurableStateUpdateStore.scala b/persistence/src/main/scala/org/apache/pekko/persistence/state/javadsl/DurableStateUpdateStore.scala
index b5ad4bec56..6fc15902c6 100644
--- a/persistence/src/main/scala/org/apache/pekko/persistence/state/javadsl/DurableStateUpdateStore.scala
+++ b/persistence/src/main/scala/org/apache/pekko/persistence/state/javadsl/DurableStateUpdateStore.scala
@@ -50,14 +50,15 @@ trait DurableStateUpdateStore[A] extends DurableStateStore[A] {
* Delete the object with the given `persistenceId` and `revision`.
*
* <p>
- * Since Pekko v1.1, if the revision does not match the current revision
+ * If the revision does not match the expected revision
* of the object, the delete operation will fail. The returned CompletionStage
* will complete with a failed result wrapping the exception.
* </p>
*
* @param persistenceId the persistenceId of the object to delete
- * @param revision the revision of the object to delete
- * @return a CompletionStage that completes when the object has been deleted
+ * @param revision the expected next revision for the `persistenceId` — this must be one more than
+ * the current (existing) revision of the object
+ * @return a CompletionStage that completes when the object has been deleted or fails if the revision does not match the expected revision of the object
*/
def deleteObject(persistenceId: String, revision: Long): CompletionStage[Done]
}
diff --git a/persistence/src/main/scala/org/apache/pekko/persistence/state/scaladsl/DurableStateUpdateStore.scala b/persistence/src/main/scala/org/apache/pekko/persistence/state/scaladsl/DurableStateUpdateStore.scala
index cce5df016e..c0aa6c9525 100644
--- a/persistence/src/main/scala/org/apache/pekko/persistence/state/scaladsl/DurableStateUpdateStore.scala
+++ b/persistence/src/main/scala/org/apache/pekko/persistence/state/scaladsl/DurableStateUpdateStore.scala
@@ -50,14 +50,15 @@ trait DurableStateUpdateStore[A] extends DurableStateStore[A] {
* Delete the object with the given `persistenceId` and `revision`.
*
* <p>
- * Since Pekko v1.1, if the revision does not match the current revision
+ * If the revision does not match the expected revision
* of the object, the delete operation will fail. The returned Future
* will complete with a failed result wrapping the exception.
* </p>
*
* @param persistenceId the persistenceId of the object to delete
- * @param revision the revision of the object to delete
- * @return a Future that completes when the object has been deleted
+ * @param revision the expected next revision for the `persistenceId` — this must be one more than
+ * the current (existing) revision of the object
+ * @return a Future that completes when the object has been deleted or fails if the revision does not match the expected revision of the object
*/
def deleteObject(persistenceId: String, revision: Long): Future[Done]
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pekko.apache.org
For additional commands, e-mail: commits-help@pekko.apache.org