class GroupDispatcher extends AnyRef
- Alphabetic
- By Inheritance
- GroupDispatcher
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new GroupDispatcher(actorSystem: ActorSystem, dispatcherRegistry: GroupDispatcherRegistry, actionHandler: GroupActionHandler, actionMsgBuilder: GroupActionMsgBuilder, groupResultId: Long)
- Annotations
- @Inject()
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 handleGroupMsg(msg: GroupMsg, studyResultId: Long, sender: ActorRef): Unit
Handle a GroupMsg received from a client.
Handle a GroupMsg received from a client. What to do with it depends on the JSON inside the GroupMsg. It can be a group action msg, a direct msg (to a particular member) or a broadcast msg to everyone in the group.
- def hasChannel(studyResultId: Long): Boolean
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def joined(studyResultId: Long): Unit
Send the 'Joined' group action message to all group members.
- def left(studyResultId: Long): Unit
Send the 'Left' group action message to all group members.
- 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 poisonChannel(studyResultId: Long): Unit
Stops and unregisters the GroupChannelActor belonging to the given study result ID.
Stops and unregisters the GroupChannelActor belonging to the given study result ID. Before it sends a 'Closed' message to the GroupChannelActor.
- def reassignChannel(studyResultId: Long, differentDispatcher: GroupDispatcher): Unit
Reassigns the given channel to a different GroupDispatcher.
Reassigns the given channel to a different GroupDispatcher. It unregisters the channel from this GroupDispatcher registers it with the different GroupDispatcher. It sets the different GroupDispatcher in the channel.
- def registerChannel(studyResultId: Long, channel: GroupChannelActor): Unit
Registers the given channel and sends an OPENED action group message to everyone in this group.
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- def unregisterChannel(studyResultId: Long): Unit
Unregisters the given channel and sends an CLOSED action group message to everyone in this group.
Unregisters the given channel and sends an CLOSED action group message to everyone in this group. Then, if the group is now empty, it unregisters this GroupDispatcher itself.
- 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()