public interface JournalTransformer
| Modifier and Type | Method and Description |
|---|---|
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.
|
java.util.concurrent.CompletionStage<akka.Done> transformAllPersistenceIds(java.util.function.Function<JournaledEvent,java.util.concurrent.CompletionStage<JournaledEvent>> transformer)
transformer - (undocumented)java.util.concurrent.CompletionStage<akka.Done> transformPersistenceId(java.lang.String persistenceId,
java.util.function.Function<JournaledEvent,java.util.concurrent.CompletionStage<JournaledEvent>> transformer)
persistenceId - (undocumented)transformer - (undocumented)