Hi guys,
In my project I was using Akka 2.4-M1 using a ClusterSingleton, which
worked as expected. Code example:
object Shoppers { def apply(excludedProductsActor: ActorRef, system:
ActorSystem): ActorRef = { val nodeRole = Some(Settings(system).nodeRole)
val singletonManager = system.actorOf( ClusterSingletonManager.props(
singletonProps = ShoppersActor.props(excludedProductsActor),
terminationMessage = PoisonPill, ClusterSingletonManagerSettings
(system).withSingletonName(ShoppersActor.name).withRole(nodeRole) ), name =
"shoppers-singleton" ) system.actorOf( ClusterSingletonProxy.props(
singletonPath = singletonManager.path.child(ShoppersActor
.name).toStringWithoutAddress, ClusterSingletonProxySettings
(system).withRole(nodeRole) ), name = "shoppers-proxy" ) }}
Yesterday I tried to upgrade to Akka 2.4-M2.
I fixed a compile error since singletonPath has become singletonManagerPath
and I also changed its value to refer to its path (instead of the
singleton's actor path, as described in the 2.4-M2 ClusterSingleton docs).
Looks like this:
object Shoppers { def apply(excludedProductsActor: ActorRef, system:
ActorSystem): ActorRef = { val nodeRole = Some(Settings(system).nodeRole)
val singletonManager = system.actorOf( ClusterSingletonManager.props(
singletonProps = ShoppersActor.props(excludedProductsActor),
terminationMessage = PoisonPill, ClusterSingletonManagerSettings
(system).withSingletonName(ShoppersActor.name).withRole(nodeRole) ), name =
"shoppers-singleton" ) system.actorOf( ClusterSingletonProxy.props(
singletonManagerPath = singletonManager.path.toStringWithoutAddress, //
which resolves to /user/shoppers-singleton ClusterSingletonProxySettings
(system).withRole(nodeRole) ), name = "shoppers-proxy" ) }}
However, now I get ask timeouts. It seems none of the messages that are
sent to the singletonProxy are received. I also tried it with a simple
"ping" / "pong" example, with no luck.
Did I make a mistake? Is the documentation for ClusterSingleton in Akka
2.4-M2 not correct? Is there a bug? Something else?
Thanks in advance for any help!
best regards,
Bas Beelen
--
>>>>>>>>>> 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.
