akka.persistence.update.cassandra.javadsl

Class CassandraJournalTransformer

java.lang.Object

akka.persistence.update.cassandra.javadsl.CassandraJournalTransformer

All Implemented Interfaces:

JournalTransformer

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 Summary

Constructors

Constructor and Description
CassandraJournalTransformer(CassandraJournalTransformer scaladslTransformer)

Method Summary

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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CassandraJournalTransformer

public CassandraJournalTransformer(CassandraJournalTransformer scaladslTransformer)

Method Detail

Identifier

public static final java.lang.String Identifier()

The default identifier for 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.

Returns:

(undocumented)

transformPersistenceId

public java.util.concurrent.CompletionStage<akka.Done> transformPersistenceId(java.lang.String persistenceId,
                                                                              java.util.function.Function<JournaledEvent,java.util.concurrent.CompletionStage<JournaledEvent>> transformer)

Description copied from interface: JournalTransformer

Transform a single persistenceId.

Specified by:

transformPersistenceId in interface JournalTransformer

Parameters:

persistenceId - (undocumented)

transformer - (undocumented)

Returns:

(undocumented)

transformAllPersistenceIds

public java.util.concurrent.CompletionStage<akka.Done> transformAllPersistenceIds(java.util.function.Function<JournaledEvent,java.util.concurrent.CompletionStage<JournaledEvent>> transformer)

Description copied from interface: JournalTransformer

Transform all persistence ids. It is expected that this is an expensive operation.

Specified by:

transformAllPersistenceIds in interface JournalTransformer

Parameters:

transformer - (undocumented)

Returns:

(undocumented)