akka.persistence.update.cassandra.scaladsl

Class CassandraJournalTransformer

java.lang.Object

akka.persistence.update.cassandra.scaladsl.CassandraJournalTransformer

All Implemented Interfaces:

akka.persistence.cassandra.journal.CassandraEventUpdate, akka.persistence.cassandra.journal.CassandraStatements, akka.persistence.cassandra.snapshot.CassandraSnapshotCleanup, JournalTransformer

public class CassandraJournalTransformer
extends java.lang.Object
implements JournalTransformer, akka.persistence.cassandra.snapshot.CassandraSnapshotCleanup, akka.persistence.cassandra.journal.CassandraEventUpdate

akka.persistence.update.scaladsl.JournalTransformer implementation for Cassandra.

It is retrieved with:

 val transformer =
   JournalUpdater(system).journalUpdaterFor[CassandraJournalTransformer](CassandraJournalTransformer.Identifier)
 

Corresponding Java 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(akka.actor.ExtendedActorSystem system, com.typesafe.config.Config cfg, java.lang.String configPath)

Method Summary

Modifier and Type	Method and Description
akka.persistence.cassandra.journal.CassandraJournalConfig	config()
java.lang.String	createKeyspace()
java.lang.String	createTable()
akka.dispatch.MessageDispatcher	ec()
akka.persistence.cassandra.journal.CassandraJournal.EventDeserializer	eventDeserializer()
static java.lang.String	Identifier() The default identifier for CassandraJournalTransformer to be used with akka.persistence.update.scaladsl.JournalUpdater#journalUpdaterFor.
akka.event.LoggingAdapter	log()
akka.stream.ActorMaterializer	materializer()
akka.persistence.cassandra.query.scaladsl.CassandraReadJournal	queries()
com.datastax.driver.core.policies.LoggingRetryPolicy	readRetryPolicy()
akka.serialization.Serialization	serialization()
akka.persistence.cassandra.session.scaladsl.CassandraSession	session()
akka.persistence.cassandra.snapshot.CassandraSnapshotStoreConfig	snapshotConfig()
scala.concurrent.Future<akka.Done>	transformAllPersistenceIds(scala.Function1<JournaledEvent,scala.concurrent.Future<JournaledEvent>> transformer) Transform all persistence ids.
scala.concurrent.Future<akka.Done>	transformPersistenceId(java.lang.String pid, scala.Function1<JournaledEvent,scala.concurrent.Future<JournaledEvent>> f) Transform a single persistenceId.

Methods inherited from class java.lang.Object

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

Methods inherited from interface akka.persistence.cassandra.snapshot.CassandraSnapshotCleanup

$init$, akka$persistence$cassandra$snapshot$CassandraSnapshotCleanup$$deleteRetryPolicy, deleteAllForPersistenceId, deleteAsync, preparedDeleteAllSnapshotsForPid, preparedDeleteAllSnapshotsForPidAndSequenceNrBetween, preparedDeleteSnapshot

Methods inherited from interface akka.persistence.cassandra.snapshot.CassandraStatements

$init$, deleteAllSnapshotForPersistenceId, deleteAllSnapshotForPersistenceIdAndSequenceNrBetween, deleteSnapshot, executeCreateKeyspaceAndTables, selectSnapshot, selectSnapshotMetadata, selectSnapshotMetadata$default$1, writeSnapshot

Methods inherited from interface akka.persistence.cassandra.journal.CassandraEventUpdate

$init$, psSelectMessages, psSelectTagPidSequenceNr, psUpdateMessage, psUpdateTagView, updateEvent

Methods inherited from interface akka.persistence.cassandra.journal.CassandraStatements

$init$, addTagsToMessagesTable, createMetadataTable, createTagScanningTable, createTagsProgressTable, createTagsTable, deleteMessage, deleteMessages, executeCreateKeyspaceAndTables, insertDeletedTo, selectDeletedTo, selectHighestSequenceNr, selectMessages, selectTagPidSequenceNr, selectTagProgress, selectTagProgressForPersistenceId, selectTagScanningForPersistenceId, tableName, updateMessagePayloadAndTags, updateMessagePayloadInTagView, writeInUse, writeMessage, writeTagProgress, writeTags, writeTagScanning

Constructor Detail

CassandraJournalTransformer

public CassandraJournalTransformer(akka.actor.ExtendedActorSystem system,
                                   com.typesafe.config.Config cfg,
                                   java.lang.String configPath)

Method Detail

Identifier

public static final java.lang.String Identifier()

The default identifier for CassandraJournalTransformer to be used with akka.persistence.update.scaladsl.JournalUpdater#journalUpdaterFor.

The value is "cassandra-journal-updater" and corresponds to the absolute path to the configuration entry.

Returns:

(undocumented)

serialization

public akka.serialization.Serialization serialization()

eventDeserializer

public akka.persistence.cassandra.journal.CassandraJournal.EventDeserializer eventDeserializer()

log

public akka.event.LoggingAdapter log()

Specified by:

log in interface akka.persistence.cassandra.journal.CassandraEventUpdate

config

public akka.persistence.cassandra.journal.CassandraJournalConfig config()

Specified by:

config in interface akka.persistence.cassandra.journal.CassandraEventUpdate

Specified by:

config in interface akka.persistence.cassandra.journal.CassandraStatements

snapshotConfig

public akka.persistence.cassandra.snapshot.CassandraSnapshotStoreConfig snapshotConfig()

Specified by:

snapshotConfig in interface akka.persistence.cassandra.snapshot.CassandraSnapshotCleanup

createKeyspace

public java.lang.String createKeyspace()

Specified by:

createKeyspace in interface akka.persistence.cassandra.journal.CassandraStatements

createTable

public java.lang.String createTable()

Specified by:

createTable in interface akka.persistence.cassandra.journal.CassandraStatements

ec

public akka.dispatch.MessageDispatcher ec()

Specified by:

ec in interface akka.persistence.cassandra.journal.CassandraEventUpdate

Specified by:

ec in interface akka.persistence.cassandra.snapshot.CassandraSnapshotCleanup

materializer

public akka.stream.ActorMaterializer materializer()

readRetryPolicy

public com.datastax.driver.core.policies.LoggingRetryPolicy readRetryPolicy()

queries

public akka.persistence.cassandra.query.scaladsl.CassandraReadJournal queries()

session

public akka.persistence.cassandra.session.scaladsl.CassandraSession session()

Specified by:

session in interface akka.persistence.cassandra.journal.CassandraEventUpdate

Specified by:

session in interface akka.persistence.cassandra.snapshot.CassandraSnapshotCleanup

transformPersistenceId

public scala.concurrent.Future<akka.Done> transformPersistenceId(java.lang.String pid,
                                                                 scala.Function1<JournaledEvent,scala.concurrent.Future<JournaledEvent>> f)

Description copied from interface: JournalTransformer

Transform a single persistenceId.

Specified by:

transformPersistenceId in interface JournalTransformer

Parameters:

pid - (undocumented)

f - (undocumented)

Returns:

(undocumented)

transformAllPersistenceIds

public scala.concurrent.Future<akka.Done> transformAllPersistenceIds(scala.Function1<JournaledEvent,scala.concurrent.Future<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)