Hello, I get strange error while sending message on remote node (see Error.txt in attach). Also in attach. is picture of basic architecture I'm using and dependencies.
How is package made: sbt console> dist (it will make one jar file which constains all classes and resource files) How do I start akka Microkernel (Bootable) modules: bin\start org.osos.synergy.akka.service.worker.WorkerKernel 2551 bin\start org.osos.synergy.akka.service.worker.WorkerKernel 2552 bin\start org.osos.synergy.akka.service.http.HttpKernel 0 All nodes are properly clustered and no errors during startup. Please help, Kresimir -- >>>>>>>>>> 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.
Starting Akka... Running Akka 2.3.2 Deploying file:/D:/Development/Projects/Synergy/akka-microkernel-sample/target/h ello-dist/bin/../deploy/akka-synergy-microkernel-sample-1.0.0.jar Starting up org.osos.synergy.akka.service.worker.WorkerKernel [INFO] [04/11/2014 11:16:49.636] [main] [Remoting] Starting remoting [INFO] [04/11/2014 11:16:50.108] [main] [Remoting] Remoting started; listening o n addresses :[akka.tcp://[email protected]:2551] [INFO] [04/11/2014 11:16:50.142] [main] [Cluster(akka://ClusterSystem)] Cluster Node [akka.tcp://[email protected]:2551] - Starting up... [INFO] [04/11/2014 11:16:50.342] [main] [Cluster(akka://ClusterSystem)] Cluster Node [akka.tcp://[email protected]:2551] - Registered cluster JMX MBean [a kka:type=Cluster] [INFO] [04/11/2014 11:16:50.342] [main] [Cluster(akka://ClusterSystem)] Cluster Node [akka.tcp://[email protected]:2551] - Started up successfully [INFO] [04/11/2014 11:16:50.357] [ClusterSystem-akka.actor.default-dispatcher-3] [Cluster(akka://ClusterSystem)] Cluster Node [akka.tcp://[email protected]. 1:2551] - Metrics will be retreived from MBeans, and may be incorrect on some pl atforms. To increase metric accuracy add the 'sigar.jar' to the classpath and th e appropriate platform-specific native libary to 'java.library.path'. Reason: ja va.lang.ClassNotFoundException: org.hyperic.sigar.Sigar [INFO] [04/11/2014 11:16:50.370] [ClusterSystem-akka.actor.default-dispatcher-3] [Cluster(akka://ClusterSystem)] Cluster Node [akka.tcp://[email protected]. 1:2551] - Metrics collection has started successfully Successfully started Akka [WARN] [04/11/2014 11:16:51.580] [ClusterSystem-akka.remote.default-remote-dispa tcher-7] [Remoting] Tried to associate with unreachable remote address [akka.tcp ://[email protected]:2552]. Address is now gated for 5000 ms, all messages to this address will be delivered to dead letters. Reason: Connection refused: no further information: /127.0.0.1:2552 [INFO] [04/11/2014 11:16:55.391] [ClusterSystem-akka.actor.default-dispatcher-6] [Cluster(akka://ClusterSystem)] Cluster Node [akka.tcp://[email protected]. 1:2551] - Node [akka.tcp://[email protected]:2551] is JOINING, roles [] [INFO] [04/11/2014 11:16:56.390] [ClusterSystem-akka.actor.default-dispatcher-18 ] [Cluster(akka://ClusterSystem)] Cluster Node [akka.tcp://[email protected] .1:2551] - Leader is moving node [akka.tcp://[email protected]:2551] to [U p] [INFO] [04/11/2014 11:17:07.913] [ClusterSystem-akka.actor.default-dispatcher-2] [Cluster(akka://ClusterSystem)] Cluster Node [akka.tcp://[email protected]. 1:2551] - Node [akka.tcp://[email protected]:5196] is JOINING, roles [] [INFO] [04/11/2014 11:17:08.380] [ClusterSystem-akka.actor.default-dispatcher-3] [Cluster(akka://ClusterSystem)] Cluster Node [akka.tcp://[email protected]. 1:2551] - Leader is moving node [akka.tcp://[email protected]:5196] to [Up ] [WARN] [04/11/2014 11:17:17.967] [ClusterSystem-akka.remote.default-remote-dispa tcher-20] [akka.tcp://[email protected]:2551/system/endpointManager/reliab leEndpointWriter-akka.tcp%3A%2F%2FClusterSystem%40127.0.0.1%3A5196-1] Associatio n with remote system [akka.tcp://[email protected]:5196] has failed, addre ss is now gated for [5000] ms. Reason is: [org.osos.synergy.akka.message.test]. [WARN] [04/11/2014 11:17:22.369] [ClusterSystem-akka.actor.default-dispatcher-16 ] [akka.tcp://[email protected]:2551/system/cluster/core/daemon] Cluster N ode [akka.tcp://[email protected]:2551] - Marking node(s) as UNREACHABLE [ Member(address = akka.tcp://[email protected]:5196, status = Up)] [INFO] [04/11/2014 11:17:24.378] [ClusterSystem-akka.actor.default-dispatcher-5] [Cluster(akka://ClusterSystem)] Cluster Node [akka.tcp://[email protected]. 1:2551] - Marking node(s) as REACHABLE [Member(address = akka.tcp://ClusterSyste [email protected]:5196, status = Up)] [ERROR] [04/11/2014 11:17:30.952] [ClusterSystem-akka.remote.default-remote-disp atcher-20] [Remoting] org.osos.synergy.akka.message.test java.lang.ClassNotFoundException: org.osos.synergy.akka.message.test at java.net.URLClassLoader$1.run(Unknown Source) at java.net.URLClassLoader$1.run(Unknown Source) at java.security.AccessController.doPrivileged(Native Method) at java.net.URLClassLoader.findClass(Unknown Source) at java.lang.ClassLoader.loadClass(Unknown Source) at sun.misc.Launcher$AppClassLoader.loadClass(Unknown Source) at java.lang.ClassLoader.loadClass(Unknown Source) at java.lang.Class.forName0(Native Method) at java.lang.Class.forName(Unknown Source) at java.io.ObjectInputStream.resolveClass(Unknown Source) at akka.util.ClassLoaderObjectInputStream.resolveClass(ClassLoaderObject InputStream.scala:19) at java.io.ObjectInputStream.readNonProxyDesc(Unknown Source) at java.io.ObjectInputStream.readClassDesc(Unknown Source) at java.io.ObjectInputStream.readOrdinaryObject(Unknown Source) at java.io.ObjectInputStream.readObject0(Unknown Source) at java.io.ObjectInputStream.readObject(Unknown Source) at akka.serialization.JavaSerializer$$anonfun$1.apply(Serializer.scala:1 36) at scala.util.DynamicVariable.withValue(DynamicVariable.scala:57) at akka.serialization.JavaSerializer.fromBinary(Serializer.scala:136) at akka.serialization.Serialization$$anonfun$deserialize$1.apply(Seriali zation.scala:104) at scala.util.Try$.apply(Try.scala:161) at akka.serialization.Serialization.deserialize(Serialization.scala:98) at akka.remote.serialization.MessageContainerSerializer.fromBinary(Messa geContainerSerializer.scala:61) at akka.serialization.Serialization$$anonfun$deserialize$1.apply(Seriali zation.scala:104) at scala.util.Try$.apply(Try.scala:161) at akka.serialization.Serialization.deserialize(Serialization.scala:98) at akka.remote.MessageSerializer$.deserialize(MessageSerializer.scala:23 ) at akka.remote.DefaultMessageDispatcher.payload$lzycompute$1(Endpoint.sc ala:55) at akka.remote.DefaultMessageDispatcher.payload$1(Endpoint.scala:55) at akka.remote.DefaultMessageDispatcher.dispatch(Endpoint.scala:73) at akka.remote.EndpointReader$$anonfun$receive$2.applyOrElse(Endpoint.sc ala:805) at akka.actor.Actor$class.aroundReceive(Actor.scala:465) at akka.remote.EndpointActor.aroundReceive(Endpoint.scala:409) 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(Abst ractDispatcher.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:19 79) at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThre ad.java:107) [WARN] [04/11/2014 11:17:35.370] [ClusterSystem-akka.actor.default-dispatcher-4] [akka.tcp://[email protected]:2551/system/cluster/core/daemon] Cluster No de [akka.tcp://[email protected]:2551] - Marking node(s) as UNREACHABLE [M ember(address = akka.tcp://[email protected]:5196, status = Up)] [INFO] [04/11/2014 11:17:37.366] [ClusterSystem-akka.actor.default-dispatcher-5] [Cluster(akka://ClusterSystem)] Cluster Node [akka.tcp://[email protected]. 1:2551] - Marking node(s) as REACHABLE [Member(address = akka.tcp://ClusterSyste [email protected]:5196, status = Up)]
libraryDependencies ++= {
Seq(
"com.typesafe.akka" % "akka-actor_2.10" % "2.3.2" %
"compile",
"com.typesafe.akka" % "akka-remote_2.10" % "2.3.2" %
"compile",
"com.typesafe.akka" % "akka-cluster_2.10" % "2.3.2" %
"compile",
"io.spray" % "spray-can" % "1.3.1" %
"compile",
"io.spray" % "spray-routing" % "1.3.1" %
"compile",
"org.json4s" % "json4s-jackson_2.10" % "3.2.8" %
"compile",
"org.json4s" % "json4s-ext_2.10" % "3.2.8" %
"compile",
"io.spray" % "spray-testkit" % "1.3.1" %
"test",
"org.scalatest" % "scalatest_2.10" % "2.1.0" %
"test",
"com.h2database" % "h2" % "1.3.175" %
"test"
)
}<<attachment: akka-router-routee.png>>
