Hello,
I'm dooing a POC with akka sharding using akka 2.4-M1. But the message
sended to sharded actor never is received. I cannot understand it. Can
someone help me please?
This is my main class:
import akka.actor.{ActorSystem, Props}
import akka.cluster.sharding.{ClusterSharding, ShardRegion}
import com.typesafe.config.ConfigFactory
import scala.concurrent.duration._
/**
* Created by matheus on 09/06/15.
*/
object ShardMain {
def main(args: Array[String]) {
startup(Seq("2552", "0", "0"))
}
def startup(ports: Seq[String]) = {
ports foreach { port =>
val config = ConfigFactory.parseString("akka.remote.netty.tcp.port=" +
port).withFallback(ConfigFactory.load())
val system = ActorSystem.create("application", config)
val idExtractor: ShardRegion.IdExtractor = {
case msg : CalculateDouble => {
println("Number " + msg.number)
(msg.number.toString, msg)
}
}
val shardResolver: ShardRegion.ShardResolver = {
case msg : CalculateDouble => {
println("ShardResolver")
(msg.number % 2).toString
}
}
ClusterSharding(system).start(
typeName = DoubleActor.shardName,
entryProps = Some(Props[DoubleActor]),
roleOverride = None,
rememberEntries = false,
idExtractor = idExtractor,
shardResolver = shardResolver
)
if(port != "2552") {
val shardActor =
ClusterSharding(system).shardRegion(DoubleActor.shardName)
import system.dispatcher
system.scheduler.schedule(5 second, 1 second)(shardActor !
CalculateDouble(1))
}
}
}
}
This is my sharded actor:
import akka.persistence.PersistentActor
/**
* Created by matheus on 09/06/15.
*/
object DoubleActor {
val shardName: String = "DoubleActor"
}
class DoubleActor extends PersistentActor{
override def receiveRecover = {
case x => println("Received " + x.toString)
}
override def receiveCommand = {
case x => println("Received " + x.toString)
}
override def persistenceId = self.path.parent.name + "/" + self.path.name
}
This is the message sended to sharded actor:
/**
* Created by matheus on 09/06/15.
*/
case class CalculateDouble(number: Long)
And this is the application.conf
akka{
actor.provider = "akka.cluster.ClusterActorRefProvider"
remote.netty.tcp {
hostname = "127.0.0.1"
port = 0
}
cluster {
seed-nodes = [
"akka.tcp://[email protected]:2552"
]
auto-down-unreachable-after = 10s
}
persistence {
journal {
plugin = "akka.persistence.journal.leveldb-shared"
leveldb-shared.store.dir = "target/shared"
}
snapshot-store{
plugin = "akka.persistence.snapshot-store.local"
local.dir = "target/snapshots"
}
}
}
Thank you so much
--
>>>>>>>>>> Read the docs: http://akka.io/docs/
>>>>>>>>>> Check the FAQ:
>>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user
---
You received this message because you are subscribed to the Google Groups "Akka
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to [email protected].
To post to this group, send email to [email protected].
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
