o
akka.stream.alpakka.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 Akka 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
- 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
-
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( ... ) @native() @HotSpotIntrinsicCandidate()
-
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
get(system: ClassicActorSystemProvider): CassandraSessionRegistry
- Definition Classes
- ExtensionId
-
def
get(system: ActorSystem): CassandraSessionRegistry
- Definition Classes
- ExtensionId
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
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() @HotSpotIntrinsicCandidate()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
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( ... )