akka.persistence.update.jdbc.javadsl

Class JdbcJournalTransformer

java.lang.Object

akka.persistence.update.jdbc.javadsl.JdbcJournalTransformer

All Implemented Interfaces:

JournalTransformer

public class JdbcJournalTransformer
extends java.lang.Object
implements JournalTransformer

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

It is retrieved with:

 JournalTransformer transformer =
   JournalUpdater.get(system).getJournalUpdaterFor(JdbcJournalTransformer.class, JdbcJournalTransformer.Identifier());
 

Corresponding Scala 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(JdbcJournalTransformer scaladslTransformer)

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.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

JdbcJournalTransformer

public JdbcJournalTransformer(JdbcJournalTransformer scaladslTransformer)

Method Detail

Identifier

public static final java.lang.String Identifier()

The default identifier for JdbcJournalTransformer to be used with akka.persistence.update.javadsl.JournalUpdater#getJournalUpdaterFor.

The value is "jdbc-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)