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
init
function will be performed once when the session is created, i.e. ifsessionFor
is called from multiple places with differentinit
it 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()