diff --git a/akka-persistence/src/main/java/akka/persistence/journal/japi/AsyncWritePlugin.java b/akka-persistence/src/main/java/akka/persistence/journal/japi/AsyncWritePlugin.java index 638656ccb1..5dc163785b 100644 --- a/akka-persistence/src/main/java/akka/persistence/journal/japi/AsyncWritePlugin.java +++ b/akka-persistence/src/main/java/akka/persistence/journal/japi/AsyncWritePlugin.java @@ -20,15 +20,19 @@ interface AsyncWritePlugin { /** * Java API, Plugin API: synchronously writes a batch of delivery confirmations to * the journal. + * + * @deprecated doAsyncWriteConfirmations will be removed, since Channels will be removed (since 2.3.4) */ - Future doAsyncWriteConfirmations(Iterable confirmations); + @Deprecated Future doAsyncWriteConfirmations(Iterable confirmations); /** * Java API, Plugin API: synchronously deletes messages identified by `messageIds` * from the journal. If `permanent` is set to `false`, the persistent messages are * marked as deleted, otherwise they are permanently deleted. + * + * @deprecated doAsyncDeleteMessages will be removed (since 2.3.4) */ - Future doAsyncDeleteMessages(Iterable messageIds, boolean permanent); + @Deprecated Future doAsyncDeleteMessages(Iterable messageIds, boolean permanent); /** * Java API, Plugin API: synchronously deletes all persistent messages up to diff --git a/akka-persistence/src/main/java/akka/persistence/journal/japi/SyncWritePlugin.java b/akka-persistence/src/main/java/akka/persistence/journal/japi/SyncWritePlugin.java index 86600827df..610fadfa61 100644 --- a/akka-persistence/src/main/java/akka/persistence/journal/japi/SyncWritePlugin.java +++ b/akka-persistence/src/main/java/akka/persistence/journal/japi/SyncWritePlugin.java @@ -18,15 +18,19 @@ interface SyncWritePlugin { /** * Java API, Plugin API: synchronously writes a batch of delivery confirmations to * the journal. + * + * @deprecated doWriteConfirmations will be removed, since Channels will be removed (since 2.3.4) */ - void doWriteConfirmations(Iterable confirmations); + @Deprecated void doWriteConfirmations(Iterable confirmations); /** * Java API, Plugin API: synchronously deletes messages identified by `messageIds` * from the journal. If `permanent` is set to `false`, the persistent messages are * marked as deleted, otherwise they are permanently deleted. + * + * @deprecated doDeleteMessages will be removed (since 2.3.4) */ - void doDeleteMessages(Iterable messageIds, boolean permanent); + @Deprecated void doDeleteMessages(Iterable messageIds, boolean permanent); /** * Java API, Plugin API: synchronously deletes all persistent messages up to diff --git a/akka-persistence/src/main/scala/akka/persistence/journal/AsyncWriteJournal.scala b/akka-persistence/src/main/scala/akka/persistence/journal/AsyncWriteJournal.scala index a90d95d846..1af1f96046 100644 --- a/akka-persistence/src/main/scala/akka/persistence/journal/AsyncWriteJournal.scala +++ b/akka-persistence/src/main/scala/akka/persistence/journal/AsyncWriteJournal.scala @@ -96,6 +96,7 @@ trait AsyncWriteJournal extends Actor with WriteJournalBase with AsyncRecovery { /** * Plugin API: asynchronously writes a batch of delivery confirmations to the journal. */ + @deprecated("writeConfirmations will be removed, since Channels will be removed.", since = "2.3.4") def asyncWriteConfirmations(confirmations: immutable.Seq[PersistentConfirmation]): Future[Unit] /** @@ -103,6 +104,7 @@ trait AsyncWriteJournal extends Actor with WriteJournalBase with AsyncRecovery { * journal. If `permanent` is set to `false`, the persistent messages are marked as * deleted, otherwise they are permanently deleted. */ + @deprecated("asyncDeleteMessages will be removed.", since = "2.3.4") def asyncDeleteMessages(messageIds: immutable.Seq[PersistenceId], permanent: Boolean): Future[Unit] /** diff --git a/akka-persistence/src/main/scala/akka/persistence/journal/SyncWriteJournal.scala b/akka-persistence/src/main/scala/akka/persistence/journal/SyncWriteJournal.scala index e940ffae8a..8d82483a68 100644 --- a/akka-persistence/src/main/scala/akka/persistence/journal/SyncWriteJournal.scala +++ b/akka-persistence/src/main/scala/akka/persistence/journal/SyncWriteJournal.scala @@ -88,6 +88,7 @@ trait SyncWriteJournal extends Actor with WriteJournalBase with AsyncRecovery { /** * Plugin API: synchronously writes a batch of delivery confirmations to the journal. */ + @deprecated("writeConfirmations will be removed, since Channels will be removed.", since = "2.3.4") def writeConfirmations(confirmations: immutable.Seq[PersistentConfirmation]): Unit /** @@ -95,6 +96,7 @@ trait SyncWriteJournal extends Actor with WriteJournalBase with AsyncRecovery { * journal. If `permanent` is set to `false`, the persistent messages are marked as * deleted, otherwise they are permanently deleted. */ + @deprecated("deleteMessages will be removed.", since = "2.3.4") def deleteMessages(messageIds: immutable.Seq[PersistenceId], permanent: Boolean): Unit /**