org.apache.pekko.stream.connectors.cassandra.scaladsl
CassandraSessionRegistry
Companion object CassandraSessionRegistry
final class CassandraSessionRegistry extends Extension
- Alphabetic
 - By Inheritance
 
- CassandraSessionRegistry
 - Extension
 - AnyRef
 - Any
 
- Hide All
 - Show All
 
- Public
 - Protected
 
Instance Constructors
-  new CassandraSessionRegistry(system: ExtendedActorSystem)
 
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
 
 -   final  def asInstanceOf[T0]: T0
- Definition Classes
 - 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 equals(arg0: AnyRef): Boolean
- Definition Classes
 - AnyRef → Any
 
 -    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()
 
 -    def hashCode(): Int
- Definition Classes
 - AnyRef → Any
 - Annotations
 - @native()
 
 -   final  def isInstanceOf[T0]: Boolean
- Definition Classes
 - Any
 
 -   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()
 
 -    def sessionFor(settings: CassandraSessionSettings): CassandraSession
Get an existing session or start a new one with the given settings, makes it possible to share one session across plugins.
Get an existing session or start a new one with the given settings, makes it possible to share one session across plugins.
Note that the session must not be stopped manually, it is shut down when the actor system is shutdown, if you need a more fine grained life cycle control, create the CassandraSession manually instead.
 -    def sessionFor(configPath: String, init: (CqlSession) => Future[Done]): CassandraSession
Get an existing session or start a new one with the given settings, makes it possible to share one session across plugins.
Get an existing session or start a new one with the given settings, makes it possible to share one session across plugins.
The
initfunction will be performed once when the session is created, i.e. ifsessionForis called from multiple places with differentinitit will only execute the first.Sessions in the session registry are closed after actor system termination.
 -    def sessionFor(configPath: String): CassandraSession
Get an existing session or start a new one with the given settings, makes it possible to share one session across plugins.
Get an existing session or start a new one with the given settings, makes it possible to share one session across plugins.
Sessions in the session registry are closed after actor system termination.
 -   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()