raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

#1059 - Removing ListenerManagement from RemoteSupport, publishing to AkkaApplication.eventHandler

Browse source
This commit is contained in:
Viktor Klang 2011-10-23 00:40:09 +02:00
parent bb0b845607
commit e1a3c9dff5
3 changed files with 4 additions and 67 deletions
Download patch file Download diff file Expand all files Collapse all files

16
akka-actor/src/main/scala/akka/remote/RemoteInterface.scala
View file

@ -185,27 +185,15 @@ case class CannotInstantiateRemoteExceptionDueToRemoteProtocolParsingErrorExcept
override def printStackTrace(printWriter: PrintWriter) = cause.printStackTrace(printWriter)
}
abstract class RemoteSupport(val app: AkkaApplication) extends ListenerManagement with RemoteServerModule with RemoteClientModule {
lazy val eventHandler: ActorRef = {
implicit object format extends StatelessActorFormat[RemoteEventHandler]
val clazz = classOf[RemoteEventHandler]
val handler = app.provider.actorOf(Props(clazz), clazz.getName, true)
// add the remote client and server listener that pipes the events to the event handler system
addListener(handler)
handler
}
abstract class RemoteSupport(val app: AkkaApplication) extends RemoteServerModule with RemoteClientModule {
def shutdown() {
eventHandler.stop()
removeListener(eventHandler)
this.shutdownClientModule()
this.shutdownServerModule()
clear
}
protected override def manageLifeCycleOfListeners = false
protected[akka] override def notifyListeners(message: ⇒ Any): Unit = super.notifyListeners(message)
protected[akka] override def notifyListeners(message: ⇒ Any): Unit = app.eventHandler.notify(message)
private[akka] val actors = new ConcurrentHashMap[String, ActorRef]
private[akka] val actorsByUuid = new ConcurrentHashMap[String, ActorRef]