public class InterruptableCassandraReadJournalProvider
extends java.lang.Object
implements akka.persistence.query.ReadJournalProvider
| Constructor and Description |
|---|
InterruptableCassandraReadJournalProvider(akka.actor.ExtendedActorSystem system,
com.typesafe.config.Config config,
java.lang.String pluginId) |
| Modifier and Type | Method and Description |
|---|---|
CassandraReplicatedEventQuery |
javadslReadJournal() |
CassandraReplicatedEventQuery |
scaladslReadJournal() |
public InterruptableCassandraReadJournalProvider(akka.actor.ExtendedActorSystem system,
com.typesafe.config.Config config,
java.lang.String pluginId)
public CassandraReplicatedEventQuery javadslReadJournal()
javadslReadJournal in interface akka.persistence.query.ReadJournalProviderpublic CassandraReplicatedEventQuery scaladslReadJournal()
scaladslReadJournal in interface akka.persistence.query.ReadJournalProvider