JournalTransformer

All Known Implementing Classes:

CassandraJournalTransformer, JdbcJournalTransformer
```
public interface JournalTransformer
```

Method Summary

All Methods Instance Methods Abstract Methods
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.

Method Detail

transformAllPersistenceIds

java.util.concurrent.CompletionStage<akka.Done> transformAllPersistenceIds(java.util.function.Function<JournaledEvent,java.util.concurrent.CompletionStage<JournaledEvent>> transformer)

Transform all persistence ids. It is expected that this is an expensive operation.

Parameters:: transformer - (undocumented)
Returns:: (undocumented)

transformPersistenceId

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.

Parameters:: persistenceId - (undocumented); transformer - (undocumented)
Returns:: (undocumented)

Interface JournalTransformer

Method Summary

Method Detail

transformAllPersistenceIds

transformPersistenceId