2016-11-17 1 views
0

J'utilise Akka Cluster et je veux écouter l'événement de MemberJoined et MemberLeft:groupe Akka pour Scala 2.10 - événements de cluster

override def preStart(): Unit = { 
    cluster.subscribe(self, classOf[MemberEvent], classOf[MemberJoined], classOf[MemberLeft]) 
} 

Le problème est qu'il nécessite la dépendance suivante:

"com.typesafe.akka" % "akka-cluster_2.11.xx" % "2.4.12" 

Mais je dois utiliser Scala 2.10 (je ne peux pas changer à 2,11) et de l'API pour Scala Akka 2.10 ces 2 événements sont manquants: Akka API for Scala 2.10 (existe sur Akka API for Scala 2.11)

Existe-t-il un autre moyen d'écouter ces événements?

override def receive = { 
    case MemberJoined(member) => println(s"member joined $member") 
    case MemberLeft(member) => println(s"member left $member") 
} 

Répondre

0

La différence n'est pas entre les versions scala, mais entre les versions Akka. Akka 2.4.x n'est pas compatible avec Scala 2.10, seul Akka 2.3.x est compilé avec Scala 2.10. Pour autant que je sache, les changements de l'implémentation de la mise en cluster sont effectués uniquement en version 2.4.x et non en version back-ported vers la version 2.3.x.