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 and Description |
|---|
JdbcJournalTransformer(JdbcJournalTransformer scaladslTransformer) |
| 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.
|
public JdbcJournalTransformer(JdbcJournalTransformer scaladslTransformer)
public static final java.lang.String Identifier()
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.
public java.util.concurrent.CompletionStage<akka.Done> transformPersistenceId(java.lang.String persistenceId,
java.util.function.Function<JournaledEvent,java.util.concurrent.CompletionStage<JournaledEvent>> transformer)
JournalTransformertransformPersistenceId in interface JournalTransformerpersistenceId - (undocumented)transformer - (undocumented)public java.util.concurrent.CompletionStage<akka.Done> transformAllPersistenceIds(java.util.function.Function<JournaledEvent,java.util.concurrent.CompletionStage<JournaledEvent>> transformer)
JournalTransformertransformAllPersistenceIds in interface JournalTransformertransformer - (undocumented)