2016-11-17 3 views
0

Я использую Akka кластер, и я хочу, чтобы слушать на случае ПользовательДат и MemberLeft:Akka кластер для Scala 2,10 - событий кластера

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 Akka для Scala 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.

Смежные вопросы