akka.persistence.multidc.internal

Interface CassandraReplicatedStatements

All Superinterfaces:

akka.persistence.cassandra.journal.CassandraStatements

All Known Implementing Classes:

CassandraReplicatedEventJournal, CassandraReplicatedEventQuery, InterruptableCassandraReplicatedEventQuery

public interface CassandraReplicatedStatements
extends akka.persistence.cassandra.journal.CassandraStatements

Method Summary

Modifier and Type	Method and Description
java.lang.String	createNotificationKeyspace(java.lang.String keyspaceName, java.lang.String replicationStrategy)
java.lang.String	createNotificationTable()
scala.concurrent.Future<akka.Done>	executeAsyncCreateNotificationKeyspace(com.datastax.driver.core.Session session, scala.concurrent.ExecutionContext ec)
scala.concurrent.Future<akka.Done>	executeCreateKeyspaceAndTables(com.datastax.driver.core.Session session, akka.persistence.cassandra.journal.CassandraJournalConfig config, scala.concurrent.ExecutionContext ec)
MultiDcConfig	multiDcConfig()
java.lang.String	notificationTableName()
java.lang.String	readNotification()
scala.concurrent.Future<akka.Done>	super$executeCreateKeyspaceAndTables(com.datastax.driver.core.Session session, akka.persistence.cassandra.journal.CassandraJournalConfig config, scala.concurrent.ExecutionContext ec)
java.lang.String	writeNotification()

Methods inherited from interface akka.persistence.cassandra.journal.CassandraStatements

addTagsToMessagesTable, config, createKeyspace, createMetadataTable, createTable, createTagScanningTable, createTagsProgressTable, createTagsTable, deleteDeletedTo, deleteMessage, deleteMessages, insertDeletedTo, selectDeletedTo, selectHighestSequenceNr, selectMessages, selectTagPidSequenceNr, selectTagProgress, selectTagProgressForPersistenceId, selectTagScanningForPersistenceId, tableName, updateMessagePayloadAndTags, updateMessagePayloadInTagView, writeInUse, writeMessage, writeTagProgress, writeTags, writeTagScanning

Method Detail

createNotificationKeyspace

java.lang.String createNotificationKeyspace(java.lang.String keyspaceName,
                                            java.lang.String replicationStrategy)

createNotificationTable

java.lang.String createNotificationTable()

executeAsyncCreateNotificationKeyspace

scala.concurrent.Future<akka.Done> executeAsyncCreateNotificationKeyspace(com.datastax.driver.core.Session session,
                                                                          scala.concurrent.ExecutionContext ec)

executeCreateKeyspaceAndTables

scala.concurrent.Future<akka.Done> executeCreateKeyspaceAndTables(com.datastax.driver.core.Session session,
                                                                  akka.persistence.cassandra.journal.CassandraJournalConfig config,
                                                                  scala.concurrent.ExecutionContext ec)

Specified by:

executeCreateKeyspaceAndTables in interface akka.persistence.cassandra.journal.CassandraStatements

multiDcConfig

MultiDcConfig multiDcConfig()

notificationTableName

java.lang.String notificationTableName()

readNotification

java.lang.String readNotification()

super$executeCreateKeyspaceAndTables

scala.concurrent.Future<akka.Done> super$executeCreateKeyspaceAndTables(com.datastax.driver.core.Session session,
                                                                        akka.persistence.cassandra.journal.CassandraJournalConfig config,
                                                                        scala.concurrent.ExecutionContext ec)

writeNotification

java.lang.String writeNotification()