Added some wiring code

processor/src/main/resources/application.conf

@@ -0,0 +1,17 @@
+akka {
+  event-handlers = ["akka.event.Logging$DefaultLogger"]
+  loglevel = "INFO"
+
+  actor {
+    provider = "akka.remote.RemoteActorRefProvider"
+  }
+
+  remote {
+    netty {
+      hostname = "127.0.0.1"
+      port = 2553
+    }
+  }
+}
+
+betting-service-actor = "akka:BettingServiceActorSystem//@127.0.0.1:2552/user/bettingService"

processor/src/main/scala/com/typesafe/akkademo/processor/BettingProcessorApplication.scala

@@ -0,0 +1,22 @@
+/**
+ *  Copyright (C) 2011-2012 Typesafe <http://typesafe.com/>
+ */
+package com.typesafe.akkademo.processor
+
+import akka.kernel.Bootable
+import akka.actor.{ Props, ActorSystem }
+import com.typesafe.config._
+import com.typesafe.akkademo.processor.service.BettingProcessor
+
+class BettingProcessorApplication extends Bootable {
+	val config = ConfigFactory.load()
+	val system = ActorSystem("BettingProcessorActorSystem", config)
+
+	def startup = {
+		system.actorOf(Props[BettingProcessor], "bettingProcessor")
+  }
+
+  def shutdown = {
+    system.shutdown()
+  }
+}

processor/src/main/scala/com/typesafe/akkademo/processor/service/BettingProcessor.scala

@@ -12,6 +12,7 @@ class BettingProcessor extends Actor {
 
   /**s
   * TASKS : 
+  * Send remote registration message to service
   * Create worker for dangerous task (using UnstableRepository actor)
   * Supervise worker -> handle errors
   * Send confirmation message back to Betting service
@@ -25,7 +26,7 @@ class BettingProcessor extends Actor {
 
 	  // ADD YOUR CODE BELOW
 	  m match { 
-		case bet: PlayerBet =>
+		  case bet: PlayerBet =>
 	  }
   }
 }

project/Build.scala

@@ -50,7 +50,7 @@ object AkkaDemoBuild extends Build {
 
 object Dependencies {
   import Dependency._
-  val akkademo = Seq(akkaActor, scalaTest, jUnit)
+  val akkademo = Seq(akkaActor, akkaKernel, scalaTest, jUnit)
 }
 
 object Dependency {
@@ -63,6 +63,7 @@ object Dependency {
   // ---- Application dependencies ----
 
   val akkaActor     = "com.typesafe.akka"         % "akka-actor"          % Version.Akka
+  val akkaKernel    = "com.typesafe.akka"         % "akka-kernel"              % Version.Akka
 
   // ---- Test dependencies ----
 

service/src/main/resources/application.conf

@@ -0,0 +1,17 @@
+akka {
+  event-handlers = ["akka.event.Logging$DefaultLogger"]
+  loglevel = "INFO"
+
+  actor {
+    provider = "akka.remote.RemoteActorRefProvider"
+  }
+
+  remote {
+    netty {
+      hostname = "127.0.0.1"
+      port = 2552
+    }
+  }
+}
+
+betting-processor-actor = "akka:BettingProcessorActorSystem//@127.0.0.1:2553/user/bettingProcessor"

service/src/main/scala/com/typesafe/akkademo/service/BettingService.scala

@@ -13,9 +13,10 @@ class BettingService extends Actor {
   * Create unique sequence/transaction number
   * Create PlayerBet and call betting processor (remotely)
   * Handle timed out transactions (scheduler)
+  * Handle registration message from betting processor + keep any message locally until there is a processor service available
   */ 
 
   def receive = {
-	case bet: Bet =>
+	  case bet: Bet =>
   }
 }

service/src/main/scala/com/typesafe/akkademo/service/BettingServiceApplication.scala

@@ -0,0 +1,21 @@
+/**
+ *  Copyright (C) 2011-2012 Typesafe <http://typesafe.com/>
+ */
+package com.typesafe.akkademo.service
+
+import akka.kernel.Bootable
+import akka.actor.{ Props, ActorSystem }
+import com.typesafe.config._
+
+class BettingServiceApplication extends Bootable {
+	val config = ConfigFactory.load()
+	val system = ActorSystem("BettingServiceActorSystem", config)
+
+	def startup = {
+		system.actorOf(Props[BettingService], "bettingService")
+  }
+
+  def shutdown = {
+    system.shutdown()
+  }
+}

service/src/main/test/scala/com/typesafe/akkademo/service/BettingServiceTester.scala

@@ -0,0 +1,31 @@
+/**
+ *  Copyright (C) 2011-2012 Typesafe <http://typesafe.com/>
+ */
+import akka.actor.ActorSystem
+import com.typesafe.config.ConfigFactory
+
+object BettingServiceTester extends App {
+	println("*** STARTING TEST OF BETTING SERVICE")
+
+	val config = ConfigFactory.parseString(""" 
+	akka {
+  	actor {
+    	provider = "akka.remote.RemoteActorRefProvider"
+  	}
+  	remote {
+    	transport = "akka.remote.netty.NettyRemoteTransport"
+    	netty {
+      	hostname = "127.0.0.1"
+      	port = 2661
+    	}
+ 	  }
+	}""")
+
+	// TODO : Implement better tests of the application
+
+	val system = ActorSystem("TestSystem", ConfigFactory.load(config))
+	val service = context.actorFor("akka://bettingServiceActorSystem@127.0.0.1:2552/user/bettingservice")
+	service ! Bet("ready_player_one", 1, 1)
+
+	println("*** DONE TESTING")
+}