Bom dia pessoal,
estou iniciando no desenvolvimento Akka, estou tendo que resolver um
problema aqui na empresa para uma solução akka para fazer um teste, porem
ao inicializar no servelt context listener, estou tendo o seguinte erro
abaixo (Alguém pode me ajudar nessa configuração?):
Erro está dando nesse método:
private Address startBackend(final Address joinAddress, final String role,
final String resultsTopic) {
* <NESSA LINHA>* * final Address realJoinAddress = (joinAddress ==
null) ? Cluster.get(actorSystem).selfAddress() : joinAddress;*
Cluster.get(actorSystem).join(realJoinAddress);
// Create the master actor
actorSystem.actorOf(getDefaultMasterProps(role, resultsTopic),
Constants.MASTER);
return realJoinAddress;
}
Segue meu arquivo de configuração como está (application.conf):
akka {
actor {
provider = "akka.cluster.ClusterActorRefProvider"
}
remote {
transport = "akka.remote.netty.NettyRemoteTransport"
log-remote-lifecycle-events = off
netty {
hostname = "totvs-00074"
port = 0
}
}
cluster {
seed-nodes = [
"akka://Workers@TOTVS-00074:2551",
"akka://Workers@TOTVS-00074:2552"]
auto-down = on
}
}
[ERROR ] SRVE0283E: Exception caught while initializing context:
akka.ConfigurationException: ActorSystem [akka://Workers] needs to have a
'ClusterActorRefProvider' enabled in the configuration, currently uses
[akka.actor.LocalActorRefProvider]
at akka.cluster.Cluster.<init>(Cluster.scala:79)
at akka.cluster.Cluster$.createExtension(Cluster.scala:42)
at akka.cluster.Cluster$.createExtension(Cluster.scala:37)
at akka.actor.ActorSystemImpl.registerExtension(ActorSystem.scala:711)
at akka.actor.ExtensionId$class.apply(Extension.scala:79)
at akka.cluster.Cluster$.apply(Cluster.scala:37)
at akka.actor.ExtensionId$class.get(Extension.scala:91)
at akka.cluster.Cluster$.get(Cluster.scala:38)
at akka.cluster.Cluster.get(Cluster.scala)
at
worker.calculator.BackendNodeStarter.startBackend(BackendNodeStarter.java:46)
at
worker.calculator.BackendNodeStarter.startupNode(BackendNodeStarter.java:29)
at
worker.calculator.ClusterNodeStarter.startup(ClusterNodeStarter.java:57)
at
br.com.totvs.tfs.fees.web.servlet.AkkaServletContextListener.contextInitialized(AkkaServletContextListener.java:26)
at
com.ibm.ws.webcontainer.webapp.WebApp.notifyServletContextCreated(WebApp.java:2228)
at [internal classes]
--
>>>>>>>>>> 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.
