|
Akka/Scala example source code file (SyncWritePlugin.java)
The SyncWritePlugin.java Akka example source code/** * Copyright (C) 2009-2014 Typesafe Inc. <http://www.typesafe.com> */ package akka.persistence.journal.japi; import akka.persistence.*; interface SyncWritePlugin { //#sync-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. */ void doWriteMessages(Iterable<PersistentRepr> messages); /** * 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) */ @Deprecated void doWriteConfirmations(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 doDeleteMessages will be removed (since 2.3.4) */ @Deprecated void doDeleteMessages(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 */ void doDeleteMessagesTo(String persistenceId, long toSequenceNr, boolean permanent); //#sync-write-plugin-api } Other Akka source code examplesHere is a short list of links related to this Akka SyncWritePlugin.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.