akka.persistence.update.jdbc.scaladsl

Class JdbcJournalTransformer

java.lang.Object

akka.persistence.update.jdbc.scaladsl.JdbcJournalTransformer

All Implemented Interfaces:

JournalTransformer

public class JdbcJournalTransformer
extends java.lang.Object
implements JournalTransformer

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

It is retrieved with:

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

Corresponding Java API is in JdbcJournalTransformer.

Configuration settings can be defined in the configuration section with the absolute path corresponding to the identifier, which is "jdbc-journal-updater" for the default Identifier(). See reference.conf.

Constructor Summary

Constructors

Constructor and Description
JdbcJournalTransformer(akka.actor.ExtendedActorSystem system, com.typesafe.config.Config cfg, java.lang.String configPath)

Method Summary

Modifier and Type	Method and Description
static java.lang.String	Identifier() The default identifier for JdbcJournalTransformer to be used with akka.persistence.update.scaladsl.JournalUpdater#journalUpdaterFor.
akka.actor.ActorRef	journal()
akka.event.LoggingAdapter	log()
akka.persistence.jdbc.query.scaladsl.JdbcReadJournal	queries()
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

Constructor Detail

JdbcJournalTransformer

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

Method Detail

Identifier

public static java.lang.String Identifier()

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

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

Returns:

(undocumented)

log

public akka.event.LoggingAdapter log()

journal

public akka.actor.ActorRef journal()

queries

public akka.persistence.jdbc.query.scaladsl.JdbcReadJournal queries()

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)