Package org.apache.pekko.persistence.query

Class PersistenceQuery

java.lang.Object

org.apache.pekko.persistence.PersistencePlugin<ReadJournal,ReadJournal,ReadJournalProvider>

org.apache.pekko.persistence.query.PersistenceQuery

All Implemented Interfaces:

Extension

public class PersistenceQuery
extends org.apache.pekko.persistence.PersistencePlugin<ReadJournal,ReadJournal,ReadJournalProvider>
implements Extension

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.pekko.persistence.PersistencePlugin

org.apache.pekko.persistence.PersistencePlugin.PluginHolder<ScalaDsl extends Object,JavaDsl extends Object>, org.apache.pekko.persistence.PersistencePlugin.PluginHolder$

Field Summary

Fields inherited from class org.apache.pekko.persistence.PersistencePlugin

org$apache$pekko$persistence$PersistencePlugin$$ev, org$apache$pekko$persistence$PersistencePlugin$$system

Constructor Summary

Constructors

Constructor	Description
PersistenceQuery(ExtendedActorSystem system)

Method Summary

Modifier and Type	Method	Description
static T	apply(ActorSystem system)
static T	apply(ClassicActorSystemProvider system)
static PersistenceQuery	createExtension(ExtendedActorSystem system)
static final boolean	equals(Object other)
static PersistenceQuery	get(ActorSystem system)
static PersistenceQuery	get(ClassicActorSystemProvider system)
final <T extends ReadJournal> T	getReadJournalFor(Class<T> clazz, String readJournalPluginId)
final <T extends ReadJournal> T	getReadJournalFor(Class<T> clazz, String readJournalPluginId, com.typesafe.config.Config readJournalPluginConfig)	Java API: Returns the pekko.persistence.query.javadsl.ReadJournal specified by the given read journal configuration entry.
static final int	hashCode()
static PersistenceQuery$	lookup()
final <T extends ReadJournal> T	readJournalFor(String readJournalPluginId)	Scala API: Returns the pekko.persistence.query.scaladsl.ReadJournal specified by the given read journal configuration entry.
final <T extends ReadJournal> T	readJournalFor(String readJournalPluginId, com.typesafe.config.Config readJournalPluginConfig)	Scala API: Returns the pekko.persistence.query.scaladsl.ReadJournal specified by the given read journal configuration entry.

Methods inherited from class org.apache.pekko.persistence.PersistencePlugin

org$apache$pekko$persistence$PersistencePlugin$$createPlugin, org$apache$pekko$persistence$PersistencePlugin$$instantiate$1, pluginFor

Methods inherited from class java.lang.Object

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

Constructor Details

PersistenceQuery

public PersistenceQuery(ExtendedActorSystem system)

Method Details

get

public static PersistenceQuery get(ActorSystem system)

get

public static PersistenceQuery get(ClassicActorSystemProvider system)

createExtension

public static PersistenceQuery createExtension(ExtendedActorSystem system)

lookup

public static PersistenceQuery$ lookup()

apply

public static T apply(ActorSystem system)

apply

public static T apply(ClassicActorSystemProvider system)

hashCode

public static final int hashCode()

equals

public static final boolean equals(Object other)

readJournalFor

public final <T extends ReadJournal> T readJournalFor(String readJournalPluginId,
 com.typesafe.config.Config readJournalPluginConfig)

Scala API: Returns the pekko.persistence.query.scaladsl.ReadJournal specified by the given read journal configuration entry.

The provided readJournalPluginConfig will be used to configure the journal plugin instead of the actor system config.

readJournalFor

public final <T extends ReadJournal> T readJournalFor(String readJournalPluginId)

Scala API: Returns the pekko.persistence.query.scaladsl.ReadJournal specified by the given read journal configuration entry.

getReadJournalFor

public final <T extends ReadJournal> T getReadJournalFor(Class<T> clazz,
 String readJournalPluginId,
 com.typesafe.config.Config readJournalPluginConfig)

Java API: Returns the pekko.persistence.query.javadsl.ReadJournal specified by the given read journal configuration entry.

getReadJournalFor

public final <T extends ReadJournal> T getReadJournalFor(Class<T> clazz,
 String readJournalPluginId)