trait ManagedActorClassification extends AnyRef
Maps ActorRefs to ActorRefs to form an EventBus where ActorRefs can listen to other ActorRefs.
All subscribers will be watched by an akka.event.ActorClassificationUnsubscriber
and unsubscribed when they terminate.
The unsubscriber actor will not be stopped automatically, and if you want to stop using the bus you should stop it yourself.
- Self Type
- ManagedActorClassification with ActorEventBus with ActorClassifier
- Alphabetic
- By Inheritance
- ManagedActorClassification
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Abstract Value Members
- abstract def classify(event: (ManagedActorClassification.this)#Event): (ManagedActorClassification.this)#Classifier
Returns the Classifier associated with the specified Event
Returns the Classifier associated with the specified Event
- Attributes
- protected
- abstract def mapSize: Int
This is a size hint for the number of Classifiers you expect to have (use powers of 2)
This is a size hint for the number of Classifiers you expect to have (use powers of 2)
- Attributes
- protected
- abstract def system: ActorSystem
- Attributes
- protected
Concrete 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
- final def associate(monitored: ActorRef, monitor: ActorRef): Boolean
- Attributes
- protected
- Annotations
- @tailrec()
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- final def dissociate(monitored: ActorRef, monitor: ActorRef): Boolean
- Attributes
- protected
- Annotations
- @tailrec()
- final def dissociate(actor: ActorRef): Unit
- Attributes
- protected
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @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
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- def publish(event: (ManagedActorClassification.this)#Event): Unit
- def subscribe(subscriber: (ManagedActorClassification.this)#Subscriber, to: (ManagedActorClassification.this)#Classifier): Boolean
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- def unsubscribe(subscriber: (ManagedActorClassification.this)#Subscriber): Unit
- def unsubscribe(subscriber: (ManagedActorClassification.this)#Subscriber, from: (ManagedActorClassification.this)#Classifier): Boolean
- lazy val unsubscriber: ActorRef
The unsubscriber takes care of unsubscribing actors, which have terminated.
The unsubscriber takes care of unsubscribing actors, which have terminated.
- Attributes
- protected
- 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])
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
Deprecated Value Members
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated
- Deprecated
(Since version 9)