2016-11-17 156 views
0

我用阿卡集羣和我要聽上MemberJoined和MemberLeft的事件:阿卡集羣 - 集羣事件

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

的問題是,它需要以下依賴:

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

但我必須使用Scala的2.10(我不能將其更改爲2.11),並從阿卡API斯卡拉2.10的2個缺少事件: Akka API for Scala 2.10(存在於Akka API for Scala 2.11

有沒有其他的方式可以聽這些事件?

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

回答

0

區別不在於scala版本,而是在Akka版本之間。 Akka 2.4.x與Scala 2.10不兼容,只有Akka 2.3.x是針對Scala 2.10編譯的。

據我所知,羣集實現的更改只在2.4.x中完成,而不是反向移植到2.3.x版本。