JournalTransformer

All Known Implementing Classes:

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

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method and Description
`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 persistenceId, scala.Function1<JournaledEvent,scala.concurrent.Future<JournaledEvent>> transformer)` Transform a single persistenceId.

Method Detail

transformAllPersistenceIds
```
scala.concurrent.Future<akka.Done> transformAllPersistenceIds(scala.Function1<JournaledEvent,scala.concurrent.Future<JournaledEvent>> transformer)
```
Transform all persistence ids. It is expected that this is an expensive operation.

Parameters:

transformer - (undocumented)

Returns:

(undocumented)

transformPersistenceId

scala.concurrent.Future<akka.Done> transformPersistenceId(java.lang.String persistenceId,
                                                          scala.Function1<JournaledEvent,scala.concurrent.Future<JournaledEvent>> transformer)

Transform a single persistenceId.

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

Interface JournalTransformer

Method Summary

Method Detail

transformAllPersistenceIds

transformPersistenceId