o
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)
Linear Supertypes
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()