diff --git a/.gitignore b/.gitignore index 8569f8f..7e4441b 100644 --- a/.gitignore +++ b/.gitignore @@ -1,3 +1,4 @@ +.DS_STORE bin/ project/ target/ diff --git a/HelloLocal/build.sbt b/HelloLocal/build.sbt index bca5351..3aba184 100644 --- a/HelloLocal/build.sbt +++ b/HelloLocal/build.sbt @@ -2,12 +2,12 @@ name := "HelloLocal" version := "1.0" -scalaVersion := "2.10.1" +scalaVersion := "2.11.8" resolvers += "Typesafe Repository" at "http://repo.typesafe.com/typesafe/releases/" libraryDependencies ++= Seq( - "com.typesafe.akka" %% "akka-actor" % "2.1.1", - "com.typesafe.akka" %% "akka-remote" % "2.1.1" + "com.typesafe.akka" %% "akka-actor" % "2.4.10", + "com.typesafe.akka" %% "akka-remote" % "2.4.10" ) diff --git a/HelloLocal/src/main/resources/application.conf b/HelloLocal/src/main/resources/application.conf index b1e4994..317da12 100644 --- a/HelloLocal/src/main/resources/application.conf +++ b/HelloLocal/src/main/resources/application.conf @@ -1,17 +1,18 @@ akka { - //loglevel = "DEBUG" + loglevel = "DEBUG" actor { provider = "akka.remote.RemoteActorRefProvider" } + remote { - transport = "akka.remote.netty.NettyRemoteTransport" - //log-sent-messages = on - //log-received-messages = on - netty { + enabled-transports = ["akka.remote.netty.tcp"] + netty.tcp { hostname = "127.0.0.1" port = 0 } - } -} + log-sent-messages = on + log-received-messages = on + } +} diff --git a/HelloLocal/src/main/scala/local/Local.scala b/HelloLocal/src/main/scala/local/Local.scala index 2394ca4..90174a3 100644 --- a/HelloLocal/src/main/scala/local/Local.scala +++ b/HelloLocal/src/main/scala/local/Local.scala @@ -13,7 +13,7 @@ object Local extends App { class LocalActor extends Actor { // create the remote actor - val remote = context.actorFor("akka://HelloRemoteSystem@127.0.0.1:5150/user/RemoteActor") + val remote = context.actorSelection("akka.tcp://HelloRemoteSystem@127.0.0.1:5150/user/RemoteActor") var counter = 0 def receive = { diff --git a/HelloRemote/build.sbt b/HelloRemote/build.sbt index 5a06858..b1ad42a 100644 --- a/HelloRemote/build.sbt +++ b/HelloRemote/build.sbt @@ -2,12 +2,12 @@ name := "HelloRemote" version := "1.0" -scalaVersion := "2.10.1" +scalaVersion := "2.11.8" resolvers += "Typesafe Repository" at "http://repo.typesafe.com/typesafe/releases/" libraryDependencies ++= Seq( - "com.typesafe.akka" %% "akka-actor" % "2.1.1", - "com.typesafe.akka" %% "akka-remote" % "2.1.1" + "com.typesafe.akka" %% "akka-actor" % "2.4.10", + "com.typesafe.akka" %% "akka-remote" % "2.4.10" ) diff --git a/HelloRemote/src/main/resources/application.conf b/HelloRemote/src/main/resources/application.conf index 0021aed..6d4af3e 100644 --- a/HelloRemote/src/main/resources/application.conf +++ b/HelloRemote/src/main/resources/application.conf @@ -1,16 +1,16 @@ akka { - //loglevel = "DEBUG" + loglevel = "DEBUG" actor { provider = "akka.remote.RemoteActorRefProvider" - } - remote { - transport = "akka.remote.netty.NettyRemoteTransport" - //log-sent-messages = on - //log-received-messages = on - netty { - hostname = "127.0.0.1" - port = 5150 - } - } + } + remote { + enabled-transports = ["akka.remote.netty.tcp"] + netty.tcp { + hostname = "127.0.0.1" + port = 5150 + } + log-sent-messages = on + log-received-messages = on + } }