org.apache.pekko.stream.connectors.cassandra.scaladsl

CassandraSessionRegistry

Companion class CassandraSessionRegistry

object CassandraSessionRegistry extends ExtensionId[CassandraSessionRegistry] with ExtensionIdProvider

This Cassandra session registry makes it possible to share Cassandra sessions between multiple use sites in the same ActorSystem (important for the Cassandra Pekko Persistence plugin where it is shared between journal, query plugin and snapshot plugin)

Source: CassandraSessionRegistry.scala

Linear Supertypes

ExtensionIdProvider, ExtensionId[CassandraSessionRegistry], AnyRef, Any

Ordering

Alphabetic
By Inheritance

Inherited

CassandraSessionRegistry
ExtensionIdProvider
ExtensionId
AnyRef
Any

Hide All
Show All

Visibility

Public
Protected

Value Members

final def !=(arg0: Any): Boolean
Definition Classes
AnyRef → Any
final def ##: Int
Definition Classes
AnyRef → Any
final def ==(arg0: Any): Boolean
Definition Classes
AnyRef → Any
def apply(system: ClassicActorSystemProvider): CassandraSessionRegistry
Definition Classes
ExtensionId
def apply(system: ActorSystem): CassandraSessionRegistry
Definition Classes
ExtensionId
final def asInstanceOf[T0]: T0
Definition Classes
Any
def clone(): AnyRef
Attributes
protected[lang]
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.CloneNotSupportedException]) @native()
def createExtension(system: ClassicActorSystemProvider): CassandraSessionRegistry
def createExtension(system: ExtendedActorSystem): CassandraSessionRegistry
Definition Classes
CassandraSessionRegistry → ExtensionId
final def eq(arg0: AnyRef): Boolean
Definition Classes
AnyRef
final def equals(other: Any): Boolean
Definition Classes
ExtensionId → AnyRef → Any
def finalize(): Unit
Attributes
protected[lang]
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.Throwable])
def get(system: ClassicActorSystemProvider): CassandraSessionRegistry
Definition Classes
ExtensionId
def get(system: ActorSystem): CassandraSessionRegistry
Definition Classes
ExtensionId
final def getClass(): Class[_ <: AnyRef]
Definition Classes
AnyRef → Any
Annotations
@native()
final def hashCode(): Int
Definition Classes
ExtensionId → AnyRef → Any
final def isInstanceOf[T0]: Boolean
Definition Classes
Any
def lookup: ExtensionId[CassandraSessionRegistry]
Definition Classes
CassandraSessionRegistry → ExtensionIdProvider
final def ne(arg0: AnyRef): Boolean
Definition Classes
AnyRef
final def notify(): Unit
Definition Classes
AnyRef
Annotations
@native()
final def notifyAll(): Unit
Definition Classes
AnyRef
Annotations
@native()
final def synchronized[T0](arg0: => T0): T0
Definition Classes
AnyRef
def toString(): String
Definition Classes
AnyRef → Any
final def wait(): Unit
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.InterruptedException])
final def wait(arg0: Long, arg1: Int): Unit
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.InterruptedException])
final def wait(arg0: Long): Unit
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.InterruptedException]) @native()

Inherited from ExtensionId[CassandraSessionRegistry]

Value Members

def apply(system: ClassicActorSystemProvider): CassandraSessionRegistry
Definition Classes
ExtensionId
def apply(system: ActorSystem): CassandraSessionRegistry
Definition Classes
ExtensionId
final def equals(other: Any): Boolean
Definition Classes
ExtensionId → AnyRef → Any
def get(system: ClassicActorSystemProvider): CassandraSessionRegistry
Definition Classes
ExtensionId
def get(system: ActorSystem): CassandraSessionRegistry
Definition Classes
ExtensionId
final def hashCode(): Int
Definition Classes
ExtensionId → AnyRef → Any

Inherited from AnyRef

Value Members

final def !=(arg0: Any): Boolean
Definition Classes
AnyRef → Any
final def ##: Int
Definition Classes
AnyRef → Any
final def ==(arg0: Any): Boolean
Definition Classes
AnyRef → Any
def clone(): AnyRef
Attributes
protected[lang]
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.CloneNotSupportedException]) @native()
final def eq(arg0: AnyRef): Boolean
Definition Classes
AnyRef
def finalize(): Unit
Attributes
protected[lang]
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.Throwable])
final def getClass(): Class[_ <: AnyRef]
Definition Classes
AnyRef → Any
Annotations
@native()
final def ne(arg0: AnyRef): Boolean
Definition Classes
AnyRef
final def notify(): Unit
Definition Classes
AnyRef
Annotations
@native()
final def notifyAll(): Unit
Definition Classes
AnyRef
Annotations
@native()
final def synchronized[T0](arg0: => T0): T0
Definition Classes
AnyRef
def toString(): String
Definition Classes
AnyRef → Any
final def wait(): Unit
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.InterruptedException])
final def wait(arg0: Long, arg1: Int): Unit
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.InterruptedException])
final def wait(arg0: Long): Unit
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.InterruptedException]) @native()

Inherited from Any

Value Members

final def asInstanceOf[T0]: T0
Definition Classes
Any
final def isInstanceOf[T0]: Boolean
Definition Classes
Any

Ungrouped

final def !=(arg0: Any): Boolean
Definition Classes
AnyRef → Any
final def ##: Int
Definition Classes
AnyRef → Any
final def ==(arg0: Any): Boolean
Definition Classes
AnyRef → Any
def apply(system: ClassicActorSystemProvider): CassandraSessionRegistry
Definition Classes
ExtensionId
def apply(system: ActorSystem): CassandraSessionRegistry
Definition Classes
ExtensionId
final def asInstanceOf[T0]: T0
Definition Classes
Any
def clone(): AnyRef
Attributes
protected[lang]
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.CloneNotSupportedException]) @native()
def createExtension(system: ClassicActorSystemProvider): CassandraSessionRegistry
def createExtension(system: ExtendedActorSystem): CassandraSessionRegistry
Definition Classes
CassandraSessionRegistry → ExtensionId
final def eq(arg0: AnyRef): Boolean
Definition Classes
AnyRef
final def equals(other: Any): Boolean
Definition Classes
ExtensionId → AnyRef → Any
def finalize(): Unit
Attributes
protected[lang]
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.Throwable])
def get(system: ClassicActorSystemProvider): CassandraSessionRegistry
Definition Classes
ExtensionId
def get(system: ActorSystem): CassandraSessionRegistry
Definition Classes
ExtensionId
final def getClass(): Class[_ <: AnyRef]
Definition Classes
AnyRef → Any
Annotations
@native()
final def hashCode(): Int
Definition Classes
ExtensionId → AnyRef → Any
final def isInstanceOf[T0]: Boolean
Definition Classes
Any
def lookup: ExtensionId[CassandraSessionRegistry]
Definition Classes
CassandraSessionRegistry → ExtensionIdProvider
final def ne(arg0: AnyRef): Boolean
Definition Classes
AnyRef
final def notify(): Unit
Definition Classes
AnyRef
Annotations
@native()
final def notifyAll(): Unit
Definition Classes
AnyRef
Annotations
@native()
final def synchronized[T0](arg0: => T0): T0
Definition Classes
AnyRef
def toString(): String
Definition Classes
AnyRef → Any
final def wait(): Unit
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.InterruptedException])
final def wait(arg0: Long, arg1: Int): Unit
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.InterruptedException])
final def wait(arg0: Long): Unit
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.InterruptedException]) @native()

Packages

CassandraSessionRegistry

Companion class CassandraSessionRegistry

object CassandraSessionRegistry extends ExtensionId[CassandraSessionRegistry] with ExtensionIdProvider

Value Members

Inherited from ExtensionId[CassandraSessionRegistry]

Value Members

Inherited from AnyRef

Value Members

Inherited from Any

Value Members

Ungrouped

CassandraSessionRegistry