Hi, Posting the error for ease of lookup (Same error with code is attached as well). Any solution/pointers to resolve this would be greatly appreciated.
--- (Running the application from SBT, auto-reloading is enabled) --- [info] play - Listening for HTTP on /0.0.0.0:9000 (Server started, use Ctrl+D to stop and go back to the console...) [info] Compiling 2 Java sources to C:\projects\eqx-fase-quotes-job\target\scala-2.10\classes... [info] play - datasource [jdbc:oracle:thin:@sv2axcrmdevdb02.corp.equinix.com:1521:SBLFASE] bound to JNDI as siebel [info] play - database [siebel] connected at jdbc:oracle:thin:@sv2axcrmdevdb02.corp.equinix.com:1521:SBLFASE [INFO] [07/08/2014 16:37:46.753] [play-internal-execution-context-1] [Remoting] Starting remoting [INFO] [07/08/2014 16:37:46.873] [play-internal-execution-context-1] [Remoting] Remoting started; listening on addresses :[akka.tcp://[email protected]:2551] [INFO] [07/08/2014 16:37:46.875] [play-internal-execution-context-1] [Remoting] Remoting now listens on addresses: [akka.tcp://[email protected]:2551] [INFO] [07/08/2014 16:37:46.886] [play-internal-execution-context-1] [Cluster(akka://Workers)] Cluster Node [akka.tcp://[email protected]:2551] - Starting up... [INFO] [07/08/2014 16:37:46.921] [play-internal-execution-context-1] [Cluster(akka://Workers)] Cluster Node [akka.tcp://[email protected]:2551] - Registered cluster JMX MBean [akka:type=Cluster] [INFO] [07/08/2014 16:37:46.921] [play-internal-execution-context-1] [Cluster(akka://Workers)] Cluster Node [akka.tcp://[email protected]:2551] - Started up successfully [INFO] [07/08/2014 16:37:46.933] [Workers-akka.actor.default-dispatcher-14] [Cluster(akka://Workers)] Cluster Node [akka.tcp://[email protected]:2551] - No seed-nodes configured, manual cluster join required [INFO] [07/08/2014 16:37:46.941] [Workers-akka.actor.default-dispatcher-2] [Cluster(akka://Workers)] Cluster Node [akka.tcp://[email protected]:2551] - Metrics will be retreived from MBeans, and may be incorrect on some platforms. To increase metric accuracy add the 'sigar.jar' to the classpath and the appropriate platform-specific native libary to 'java.library.path'. Reason: java.lang.ClassNotFoundException: org.hyperic.sigar.Sigar [INFO] [07/08/2014 16:37:46.945] [Workers-akka.actor.default-dispatcher-2] [Cluster(akka://Workers)] Cluster Node [akka.tcp://[email protected]:2551] - Metrics collection has started successfully [INFO] [07/08/2014 16:37:51.989] [play-internal-execution-context-1] [Remoting] Starting remoting [INFO] [07/08/2014 16:37:52.003] [play-internal-execution-context-1] [Remoting] Remoting started; listening on addresses :[akka.tcp://[email protected]:10227] [INFO] [07/08/2014 16:37:52.003] [play-internal-execution-context-1] [Remoting] Remoting now listens on addresses: [akka.tcp://[email protected]:10227] [INFO] [07/08/2014 16:37:52.003] [play-internal-execution-context-1] [Cluster(akka://Workers)] Cluster Node [akka.tcp://[email protected]:10227] - Starting up... [INFO] [07/08/2014 16:37:52.005] [play-internal-execution-context-1] [Cluster(akka://Workers)] Cluster Node [akka.tcp://[email protected]:10227] - Started up successfully [INFO] [07/08/2014 16:37:52.005] [Workers-akka.actor.default-dispatcher-7] [Cluster(akka://Workers)] Cluster Node [akka.tcp://[email protected]:10227] - Metrics will be retreived from MBeans, and may be incorrect on some platforms. To increase metric accuracy add the 'sigar.jar' to the classpath and the appropriate platform-specific native libary to 'java.library.path'. Reason: java.lang.ClassNotFoundException: org.hyperic.sigar.Sigar [INFO] [07/08/2014 16:37:52.005] [Workers-akka.actor.default-dispatcher-7] [Cluster(akka://Workers)] Cluster Node [akka.tcp://[email protected]:10227] - Metrics collection has started successfully [INFO] [07/08/2014 16:37:52.006] [Workers-akka.actor.default-dispatcher-8] [Cluster(akka://Workers)] Cluster Node [akka.tcp://[email protected]:10227] - No seed-nodes configured, manual cluster join required OnStart in GLobal......worer is started .....akka.tcp://[email protected]:2551 [INFO] [07/08/2014 16:37:57.048] [play-internal-execution-context-1] [Remoting] Starting remoting [INFO] [07/08/2014 16:37:57.061] [play-internal-execution-context-1] [Remoting] Remoting started; listening on addresses :[akka.tcp://[email protected]:10241] [INFO] [07/08/2014 16:37:57.062] [play-internal-execution-context-1] [Remoting] Remoting now listens on addresses: [akka.tcp://[email protected]:10241] [INFO] [07/08/2014 16:37:57.062] [play-internal-execution-context-1] [Cluster(akka://Workers)] Cluster Node [akka.tcp://[email protected]:10241] - Starting up... [INFO] [07/08/2014 16:37:57.063] [play-internal-execution-context-1] [Cluster(akka://Workers)] Cluster Node [akka.tcp://[email protected]:10241] - Started up successfully [INFO] [07/08/2014 16:37:57.066] [Workers-akka.actor.default-dispatcher-10] [Cluster(akka://Workers)] Cluster Node [akka.tcp://[email protected]:10241] - No seed-nodes configured, manual cluster join required OnStart in GLobal......frontend is started .....akka.tcp://[email protected]:2551 [INFO] [07/08/2014 16:37:57.075] [Workers-akka.actor.default-dispatcher-6] [Cluster(akka://Workers)] Cluster Node [akka.tcp://[email protected]:10241] - Metrics will be retreived from MBeans, and may be incorrect on some platforms. To increase metric accuracy add the 'sigar.jar' to the classpath and the appropriate platform-specific native libary to 'java.library.path'. Reason: java.lang.ClassNotFoundException: org.hyperic.sigar.Sigar [INFO] [07/08/2014 16:37:57.075] [Workers-akka.actor.default-dispatcher-6] [Cluster(akka://Workers)] Cluster Node [akka.tcp://[email protected]:10241] - Metrics collection has started successfully [INFO] [07/08/2014 16:37:57.089] [play-internal-execution-context-1] [Remoting] Starting remoting [INFO] [07/08/2014 16:37:57.086] [Workers-akka.actor.default-dispatcher-9] [Remoting] Starting remoting [INFO] [07/08/2014 16:37:57.103] [Workers-akka.actor.default-dispatcher-9] [Remoting] Remoting started; listening on addresses :[akka.tcp://[email protected]:10267] [INFO] [07/08/2014 16:37:57.104] [Workers-akka.actor.default-dispatcher-9] [Remoting] Remoting now listens on addresses: [akka.tcp://[email protected]:10267] [INFO] [07/08/2014 16:37:57.104] [play-internal-execution-context-1] [Remoting] Remoting started; listening on addresses :[akka.tcp://[email protected]:10268] [INFO] [07/08/2014 16:37:57.104] [play-internal-execution-context-1] [Remoting] Remoting now listens on addresses: [akka.tcp://[email protected]:10268] [INFO] [07/08/2014 16:37:57.105] [Workers-akka.actor.default-dispatcher-9] [Cluster(akka://Workers)] Cluster Node [akka.tcp://[email protected]:10267] - Starting up... [INFO] [07/08/2014 16:37:57.105] [play-internal-execution-context-1] [Cluster(akka://application)] Cluster Node [akka.tcp://[email protected]:10268] - Starting up... [INFO] [07/08/2014 16:37:57.107] [Workers-akka.actor.default-dispatcher-9] [Cluster(akka://Workers)] Cluster Node [akka.tcp://[email protected]:10267] - Started up successfully [INFO] [07/08/2014 16:37:57.108] [Workers-akka.actor.default-dispatcher-3] [Cluster(akka://Workers)] Cluster Node [akka.tcp://[email protected]:10267] - Metrics will be retreived from MBeans, and may be incorrect on some platforms. To increase metric accuracy add the 'sigar.jar' to the classpath and the appropriate platform-specific native libary to 'java.library.path'. Reason: java.lang.ClassNotFoundException: org.hyperic.sigar.Sigar [INFO] [07/08/2014 16:37:57.109] [Workers-akka.actor.default-dispatcher-3] [Cluster(akka://Workers)] Cluster Node [akka.tcp://[email protected]:10267] - Metrics collection has started successfully [info] play - Starting application default Akka system. [INFO] [07/08/2014 16:37:57.107] [play-internal-execution-context-1] [Cluster(akka://application)] Cluster Node [akka.tcp://[email protected]:10268] - Started up successfully [INFO] [07/08/2014 16:37:57.111] [application-akka.actor.default-dispatcher-6] [Cluster(akka://application)] Cluster Node [akka.tcp://[email protected]:10268] - Metrics will be retreived from MBeans, and may be incorrect on some platforms. To increase metric accuracy add the 'sigar.jar' to the classpath and the appropriate platform-specific native libary to 'java.library.path'. Reason: java.lang.ClassNotFoundException: org.hyperic.sigar.Sigar [INFO] [07/08/2014 16:37:57.111] [application-akka.actor.default-dispatcher-6] [Cluster(akka://application)] Cluster Node [akka.tcp://[email protected]:10268] - Metrics collection has started successfully [INFO] [07/08/2014 16:37:57.111] [Workers-akka.actor.default-dispatcher-4] [Cluster(akka://Workers)] Cluster Node [akka.tcp://[email protected]:10267] - No seed-nodes configured, manual cluster join required [INFO] [07/08/2014 16:37:57.111] [application-akka.actor.default-dispatcher-5] [Cluster(akka://application)] Cluster Node [akka.tcp://[email protected]:10268] - No seed-nodes configured, manual cluster join required [error] p.nettyException - Exception caught in Netty java.lang.NoSuchMethodError: akka.actor.ActorSystem.dispatcher()Lscala/concurrent/ExecutionContext; at play.core.Invoker$.<init>(Invoker.scala:24) ~[play_2.10-2.2.3.jar:2.2.3] at play.core.Invoker$.<clinit>(Invoker.scala) ~[play_2.10-2.2.3.jar:2.2.3] at play.api.libs.concurrent.Execution$Implicits$.defaultContext$lzycompute(Execution.scala:7) ~[play_2.10-2.2.3.jar:2.2.3] at play.api.libs.concurrent.Execution$Implicits$.defaultContext(Execution.scala:6) ~[play_2.10-2.2.3.jar:2.2.3] at play.api.libs.concurrent.Execution$.<init>(Execution.scala:10) ~[play_2.10-2.2.3.jar:2.2.3] at play.api.libs.concurrent.Execution$.<clinit>(Execution.scala) ~[play_2.10-2.2.3.jar:2.2.3] [error] p.nettyException - Exception caught in Netty java.lang.NoClassDefFoundError: Could not initialize class play.api.libs.concurrent.Execution$ at play.core.server.netty.PlayDefaultUpstreamHandler.handleAction$1(PlayDefaultUpstreamHandler.scala:197) ~[play_2.10-2.2.3.jar:2.2.3] at play.core.server.netty.PlayDefaultUpstreamHandler.messageReceived(PlayDefaultUpstreamHandler.scala:170) ~[play_2.10-2.2.3.jar:2.2.3] at com.typesafe.netty.http.pipelining.HttpPipeliningHandler.messageReceived(HttpPipeliningHandler.java:62) ~[netty-http-pipelining-1.1.2.jar:na] at org.jboss.netty.handler.codec.http.HttpContentDecoder.messageReceived(HttpContentDecoder.java:108) ~[netty-3.8.0.Final.jar:na] at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:296) ~[netty-3.8.0.Final.jar:na] at org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived(FrameDecoder.java:459) ~[netty-3.8.0.Final.jar:na] [INFO] [07/08/2014 16:38:07.923] [Workers-akka.actor.default-dispatcher-3] [akka://Workers/user/producer] Produced work: 1 [INFO] [07/08/2014 16:38:12.942] [Workers-akka.actor.default-dispatcher-9] [akka://Workers/user/producer] Work not accepted, retry after a while [INFO] [07/08/2014 16:38:20.982] [Workers-akka.actor.default-dispatcher-2] [akka://Workers/user/producer] Work not accepted, retry after a while [INFO] [07/08/2014 16:38:29.021] [Workers-akka.actor.default-dispatcher-5] [akka://Workers/user/producer] Work not accepted, retry after a while [INFO] [07/08/2014 16:38:37.061] [Workers-akka.actor.default-dispatcher-5] [akka://Workers/user/producer] Work not accepted, retry after a while [INFO] [07/08/2014 16:38:45.095] [Workers-akka.actor.default-dispatcher-4] [akka://Workers/user/producer] Work not accepted, retry after a while [INFO] [07/08/2014 16:38:53.126] [Workers-akka.actor.default-dispatcher-3] [akka://Workers/user/producer] Work not accepted, retry after a while [INFO] [07/08/2014 16:39:01.163] [Workers-akka.actor.default-dispatcher-7] [akka://Workers/user/producer] Work not accepted, retry after a while [INFO] [07/08/2014 16:39:09.208] [Workers-akka.actor.default-dispatcher-22] [akka://Workers/user/producer] Work not accepted, retry after a while [INFO] [07/08/2014 16:39:17.234] [Workers-akka.actor.default-dispatcher-10] [akka://Workers/user/producer] Work not accepted, retry after a while [INFO] [07/08/2014 16:39:25.266] [Workers-akka.actor.default-dispatcher-9] [akka://Workers/user/producer] Work not accepted, retry after a while [INFO] [07/08/2014 16:39:33.309] [Workers-akka.actor.default-dispatcher-6] [akka://Workers/user/producer] Work not accepted, retry after a while [INFO] [07/08/2014 16:39:41.350] [Workers-akka.actor.default-dispatcher-5] [akka://Workers/user/producer] Work not accepted, retry after a while [INFO] [07/08/2014 16:39:49.380] [Workers-akka.actor.default-dispatcher-5] [akka://Workers/user/producer] Work not accepted, retry after a while [INFO] [07/08/2014 16:39:57.402] [Workers-akka.actor.default-dispatcher-7] [akka://Workers/user/producer] Work not accepted, retry after a while [INFO] [07/08/2014 16:40:05.428] [Workers-akka.actor.default-dispatcher-4] [akka://Workers/user/producer] Work not accepted, retry after a while [INFO] [07/08/2014 16:40:13.459] [Workers-akka.actor.default-dispatcher-8] [akka://Workers/user/producer] Work not accepted, retry after a while [INFO] [07/08/2014 16:40:21.490] [Workers-akka.actor.default-dispatcher-8] [akka://Workers/user/producer] Work not accepted, retry after a while [INFO] [07/08/2014 16:40:29.522] [Workers-akka.actor.default-dispatcher-12] [akka://Workers/user/producer] Work not accepted, retry after a while [INFO] [07/08/2014 16:40:37.562] [Workers-akka.actor.default-dispatcher-11] [akka://Workers/user/producer] Work not accepted, retry after a while [INFO] [07/08/2014 16:40:45.605] [Workers-akka.actor.default-dispatcher-11] [akka://Workers/user/producer] Work not accepted, retry after a while [INFO] [07/08/2014 16:40:53.632] [Workers-akka.actor.default-dispatcher-7] [akka://Workers/user/producer] Work not accepted, retry after a while [INFO] [07/08/2014 16:41:01.655] [Workers-akka.actor.default-dispatcher-8] [akka://Workers/user/producer] Work not accepted, retry after a while [INFO] [07/08/2014 16:41:09.682] [Workers-akka.actor.default-dispatcher-6] [akka://Workers/user/producer] Work not accepted, retry after a while [INFO] [07/08/2014 16:41:17.706] [Workers-akka.actor.default-dispatcher-9] [akka://Workers/user/producer] Work not accepted, retry after a while [INFO] [07/08/2014 16:41:25.736] [Workers-akka.actor.default-dispatcher-22] [akka://Workers/user/producer] Work not accepted, retry after a while [INFO] [07/08/2014 16:41:33.776] [Workers-akka.actor.default-dispatcher-10] [akka://Workers/user/producer] Work not accepted, retry after a while [INFO] [07/08/2014 16:41:41.807] [Workers-akka.actor.default-dispatcher-3] [akka://Workers/user/producer] Work not accepted, retry after a while [INFO] [07/08/2014 16:41:49.835] [Workers-akka.actor.default-dispatcher-4] [akka://Workers/user/producer] Work not accepted, retry after a while [INFO] [07/08/2014 16:41:57.867] [Workers-akka.actor.default-dispatcher-2] [akka://Workers/user/producer] Work not accepted, retry after a while [ERROR] [07/08/2014 18:02:32.213] [Workers-akka.actor.default-dispatcher-21] [akka://Workers/user/clusterClient] Couldn't enqueue message Envelope(SendToAll(/user/master/active,RegisterWorker{workerId='1104beb5-28d8-4ed9-bf21-ca070fbb0a10'}),Actor[akka://Workers/user/worker#-372702490]) to stash of Actor[akka://Workers/user/clusterClient#809087438] akka.actor.StashOverflowException: Couldn't enqueue message Envelope(SendToAll(/user/master/active,RegisterWorker{workerId='1104beb5-28d8-4ed9-bf21-ca070fbb0a10'}),Actor[akka://Workers/user/worker#-372702490]) to stash of Actor[akka://Workers/user/clusterClient#809087438] at akka.actor.StashSupport$class.stash(Stash.scala:165) at akka.contrib.pattern.ClusterClient.stash(ClusterClient.scala:118) at akka.contrib.pattern.ClusterClient$$anonfun$establishing$1.applyOrElse(ClusterClient.scala:164) at akka.actor.Actor$class.aroundReceive(Actor.scala:465) at akka.contrib.pattern.ClusterClient.aroundReceive(ClusterClient.scala:118) at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) at akka.actor.ActorCell.invoke(ActorCell.scala:487) at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:238) at akka.dispatch.Mailbox.run(Mailbox.scala:220) at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:393) at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) [INFO] [07/08/2014 18:02:32.970] [Workers-akka.actor.default-dispatcher-22] [akka://Workers/user/producer] Work not accepted, retry after a while Thanks, Mani On Tuesday, July 8, 2014 11:41:42 AM UTC+8, Manikandan Kaliyaperumal wrote: > > Hi, > > I have followed this distributed Workers example > https://github.com/typesafehub/activator-akka-distributed-workers/ and > created distributed workers with Master in java. > > I have started the "backed" on port 2551 as mentioned in the reference > Also, started worker and frontend using port "0" > > But, the issue is i am not able to submit the work to Master from > WorkProducer and i am getting Work not accepted message back. I have > attached the cluster nodes startup log and my worker and master > implementations. > > Can you please help to resolve this? > > Thanks in advance! > > Regards, > Mani > > > -- >>>>>>>>>> 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.
