class MultiplexingSchemaListener extends SchemaChangeListener
Uses an internal TrieMap to collect incoming listeners based on their hashCodes. This means that identical objects cannot be added, if you need to add the same SchemaListener more than once be sure that it is not the identical object.
- Alphabetic
- By Inheritance
- MultiplexingSchemaListener
- SchemaChangeListener
- AutoCloseable
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Instance Constructors
- new MultiplexingSchemaListener()
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
addListener(listener: SchemaChangeListener): Option[SchemaChangeListener]
Adds a listener.
Adds a listener. If another listener already exists with the same hashcode it will be overridden by this listener.
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
clearListeners(): Unit
Removes all registered listeners
-
def
clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
-
def
close(): Unit
- Definition Classes
- MultiplexingSchemaListener → AutoCloseable
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
def
getListeners(): Iterable[SchemaChangeListener]
Returns a read only snapshot representation of current registered listeners.
Returns a read only snapshot representation of current registered listeners. This is thread-safe but may contain references to items which were already removed or be missing elements that were just added.
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- val log: Logger
-
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
onAggregateCreated(aggregate: AggregateMetadata): Unit
- Definition Classes
- MultiplexingSchemaListener → SchemaChangeListener
-
def
onAggregateDropped(aggregate: AggregateMetadata): Unit
- Definition Classes
- MultiplexingSchemaListener → SchemaChangeListener
-
def
onAggregateUpdated(current: AggregateMetadata, previous: AggregateMetadata): Unit
- Definition Classes
- MultiplexingSchemaListener → SchemaChangeListener
-
def
onFunctionCreated(function: FunctionMetadata): Unit
- Definition Classes
- MultiplexingSchemaListener → SchemaChangeListener
-
def
onFunctionDropped(function: FunctionMetadata): Unit
- Definition Classes
- MultiplexingSchemaListener → SchemaChangeListener
-
def
onFunctionUpdated(current: FunctionMetadata, previous: FunctionMetadata): Unit
- Definition Classes
- MultiplexingSchemaListener → SchemaChangeListener
-
def
onKeyspaceCreated(keyspace: KeyspaceMetadata): Unit
- Definition Classes
- MultiplexingSchemaListener → SchemaChangeListener
-
def
onKeyspaceDropped(keyspace: KeyspaceMetadata): Unit
- Definition Classes
- MultiplexingSchemaListener → SchemaChangeListener
-
def
onKeyspaceUpdated(current: KeyspaceMetadata, previous: KeyspaceMetadata): Unit
- Definition Classes
- MultiplexingSchemaListener → SchemaChangeListener
-
def
onSessionReady(arg0: Session): Unit
- Definition Classes
- SchemaChangeListener
-
def
onTableCreated(table: TableMetadata): Unit
- Definition Classes
- MultiplexingSchemaListener → SchemaChangeListener
-
def
onTableDropped(table: TableMetadata): Unit
- Definition Classes
- MultiplexingSchemaListener → SchemaChangeListener
-
def
onTableUpdated(current: TableMetadata, previous: TableMetadata): Unit
- Definition Classes
- MultiplexingSchemaListener → SchemaChangeListener
-
def
onUserDefinedTypeCreated(type: UserDefinedType): Unit
- Definition Classes
- MultiplexingSchemaListener → SchemaChangeListener
-
def
onUserDefinedTypeDropped(type: UserDefinedType): Unit
- Definition Classes
- MultiplexingSchemaListener → SchemaChangeListener
-
def
onUserDefinedTypeUpdated(current: UserDefinedType, previous: UserDefinedType): Unit
- Definition Classes
- MultiplexingSchemaListener → SchemaChangeListener
-
def
onViewCreated(view: ViewMetadata): Unit
- Definition Classes
- MultiplexingSchemaListener → SchemaChangeListener
-
def
onViewDropped(view: ViewMetadata): Unit
- Definition Classes
- MultiplexingSchemaListener → SchemaChangeListener
-
def
onViewUpdated(current: ViewMetadata, previous: ViewMetadata): Unit
- Definition Classes
- MultiplexingSchemaListener → SchemaChangeListener
-
def
registeredListenerCount(): Int
Returns the current number of registered listeners
-
def
removeListener(listener: SchemaChangeListener): Option[SchemaChangeListener]
Removes a listener with the same hashcode as the argument listener if it exists
-
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( ... )
-
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()