public class CassandraJournalTransformer extends java.lang.Object implements JournalTransformer
akka.persistence.update.javadsl.JournalTransformer implementation for Cassandra.
It is retrieved with:
JournalTransformer transformer =
JournalUpdater.get(system).getJournalUpdaterFor(CassandraJournalTransformer.class, CassandraJournalTransformer.Identifier());
Corresponding Scala API is in CassandraJournalTransformer.
Configuration settings can be defined in the configuration section with the
absolute path corresponding to the identifier, which is "cassandra-journal-updater"
for the default Identifier(). See reference.conf.
| Constructor and Description |
|---|
CassandraJournalTransformer(CassandraJournalTransformer scaladslTransformer) |
| Modifier and Type | Method and Description |
|---|---|
static java.lang.String |
Identifier()
The default identifier for
CassandraJournalTransformer to be used with
akka.persistence.update.javadsl.JournalUpdater#getJournalUpdaterFor. |
java.util.concurrent.CompletionStage<akka.Done> |
transformAllPersistenceIds(java.util.function.Function<JournaledEvent,java.util.concurrent.CompletionStage<JournaledEvent>> transformer)
Transform all persistence ids.
|
java.util.concurrent.CompletionStage<akka.Done> |
transformPersistenceId(java.lang.String persistenceId,
java.util.function.Function<JournaledEvent,java.util.concurrent.CompletionStage<JournaledEvent>> transformer)
Transform a single persistenceId.
|
public CassandraJournalTransformer(CassandraJournalTransformer scaladslTransformer)
public static final java.lang.String Identifier()
CassandraJournalTransformer to be used with
akka.persistence.update.javadsl.JournalUpdater#getJournalUpdaterFor.
The value is "cassandra-journal-updater" and corresponds
to the absolute path to the configuration entry.
public java.util.concurrent.CompletionStage<akka.Done> transformPersistenceId(java.lang.String persistenceId,
java.util.function.Function<JournaledEvent,java.util.concurrent.CompletionStage<JournaledEvent>> transformer)
JournalTransformertransformPersistenceId in interface JournalTransformerpersistenceId - (undocumented)transformer - (undocumented)public java.util.concurrent.CompletionStage<akka.Done> transformAllPersistenceIds(java.util.function.Function<JournaledEvent,java.util.concurrent.CompletionStage<JournaledEvent>> transformer)
JournalTransformertransformAllPersistenceIds in interface JournalTransformertransformer - (undocumented)