akka.persistence.multidc.testkit

Class InterruptableCassandraReadJournalProvider

java.lang.Object

akka.persistence.multidc.testkit.InterruptableCassandraReadJournalProvider

All Implemented Interfaces:

akka.persistence.query.ReadJournalProvider

public class InterruptableCassandraReadJournalProvider
extends java.lang.Object
implements akka.persistence.query.ReadJournalProvider

INTERNAL API

Constructor Summary

Constructors

Constructor and Description
InterruptableCassandraReadJournalProvider(akka.actor.ExtendedActorSystem system, com.typesafe.config.Config config, java.lang.String pluginId)

Method Summary

Modifier and Type	Method and Description
CassandraReplicatedEventQuery	javadslReadJournal()
CassandraReplicatedEventQuery	scaladslReadJournal()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

InterruptableCassandraReadJournalProvider

public InterruptableCassandraReadJournalProvider(akka.actor.ExtendedActorSystem system,
                                                 com.typesafe.config.Config config,
                                                 java.lang.String pluginId)

Method Detail

javadslReadJournal

public CassandraReplicatedEventQuery javadslReadJournal()

Specified by:

javadslReadJournal in interface akka.persistence.query.ReadJournalProvider

scaladslReadJournal

public CassandraReplicatedEventQuery scaladslReadJournal()

Specified by:

scaladslReadJournal in interface akka.persistence.query.ReadJournalProvider