ConsumerBot.scala

package data_distribution

import akka.actor.{Actor, ActorLogging, ActorRef}
import akka.cluster.Cluster
import akka.cluster.ddata.Replicator._
import akka.cluster.ddata.{DistributedData, ORSetKey}

/**
  * Created by pabloperezgarcia on 19/02/2017.
  *
  * In this example the consumer it will subscribe to a specific ORSetKey and it will receive all changes happens
  * in the ORSetKey
  *
  * http://doc.akka.io/docs/akka/2.4.16/scala/distributed-data.html
  */
class ConsumerBot(name:String) extends Actor with ActorLogging {


  implicit val node = Cluster(context.system)

  val DataKey: ORSetKey[String] = ORSetKey[String]("uniqueKey")

  val replicator: ActorRef = DistributedData(context.system).replicator

  replicator ! Subscribe(DataKey, self)

  def receive = {

    case _: UpdateResponse[_] => //ignore

    case replicatorMessage@Changed(DataKey) =>
      val data = replicatorMessage.get(DataKey)
      log.info(s"$name: {}", data.elements)
  }

}