scala - Akka remoting: Remote subscribed event listener custom serialising a Watch message -


i have following remote actor set up.

actorsystem.actorselection(remoteconfig.getstring("/myeventlistener")).resolveone().map{ar =>     actorsystem.eventstream.subscribe(ar, classof[myevent])   } 

i have own custom serialization. issue gets sent watch message has following signature:

private[akka] final case class watch(watchee: internalactorref, watcher: internalactorref) extends systemmessage 

which not straight forward serialize. suggestions on how proceed on one? sending remote message references internalactorref seems bit of odd one.

and note use other remote actors directly (not event listeners), these dont sent watch message:

val emailservice = actorsystem.actorselection(remoteconfig.getstring("/emailcommandhandler")) 


Comments

Popular posts from this blog

many to many - Django Rest Framework ManyToMany filter multiple values -

java - Jasper subreport showing only one entry from the JSON data source when embedded in the Title band -

Java Entity Manager - JSON reader was expecting a value but found 'db' -