|
Akka/Scala example source code file (AsyncWritePlugin.java)
The AsyncWritePlugin.java Akka example source code/** * Copyright (C) 2009-2014 Typesafe Inc. <http://www.typesafe.com> */ package akka.persistence.journal.japi; import scala.concurrent.Future; import akka.persistence.*; interface AsyncWritePlugin { //#async-write-plugin-api /** * Java API, Plugin API: synchronously writes a batch of persistent messages to the * journal. The batch write must be atomic i.e. either all persistent messages in the * batch are written or none. */ Future<Void> doAsyncWriteMessages(Iterable<PersistentRepr> messages); /** * 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) */ @Deprecated Future<Void> doAsyncWriteConfirmations(Iterable<PersistentConfirmation> 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) */ @Deprecated Future<Void> doAsyncDeleteMessages(Iterable<PersistentId> messageIds, boolean permanent); /** * Java API, Plugin API: synchronously deletes all persistent messages up to * `toSequenceNr`. If `permanent` is set to `false`, the persistent messages are * marked as deleted, otherwise they are permanently deleted. * * @see AsyncRecoveryPlugin */ Future<Void> doAsyncDeleteMessagesTo(String persistenceId, long toSequenceNr, boolean permanent); //#async-write-plugin-api } Other Akka source code examplesHere is a short list of links related to this Akka AsyncWritePlugin.java source code file: |
... this post is sponsored by my books ... | |
#1 New Release! |
FP Best Seller |
Copyright 1998-2021 Alvin Alexander, alvinalexander.com
All Rights Reserved.
A percentage of advertising revenue from
pages under the /java/jwarehouse
URI on this website is
paid back to open source projects.