akka.stream.alpakka.cassandra.javadsl
CassandraSessionRegistry
Companion object CassandraSessionRegistry
final class CassandraSessionRegistry extends AnyRef
- Alphabetic
- By Inheritance
- CassandraSessionRegistry
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
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( ... ) @native() @HotSpotIntrinsicCandidate()
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
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() @HotSpotIntrinsicCandidate()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
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.
-
def
sessionFor(configPath: String, init: Function[CqlSession, CompletionStage[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(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )