akka.persistence.update.cassandra
akka.persistence.update.javadsl.JournalTransformer implementation for Cassandra.
akka.persistence.update.javadsl.JournalTransformer
It is retrieved with:
JournalTransformer transformer = JournalUpdater.get(system).getJournalUpdaterFor(CassandraJournalTransformer.class, CassandraJournalTransformer.Identifier());
Corresponding Scala API is in akka.persistence.update.cassandra.scaladsl.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 CassandraJournalTransformer#Identifier. See reference.conf.
"cassandra-journal-updater"
reference.conf
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 akka.persistence.update.cassandra.scaladsl.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 CassandraJournalTransformer#Identifier. Seereference.conf
.