| import org.enmas.pomdp._ | |
| import org.enmas.pomdp.State.Implicits._ | |
| case class SimplePOMDP extends POMDP ( | |
| name = "Example POMDP", | |
| description = "Just a simple POMDP", | |
| agentConstraints = List( |
| import org.enmas.pomdp.{Agent, Action, State} | |
| import scala.util.Random | |
| class RandomAgent extends Agent { | |
| val random = new scala.util.Random | |
| def name = "Random Agent" | |
| def policy(observation: State, reward: Float) = |
| import akka.actor._, akka.actor.Actor._ | |
| case object Ping | |
| case object Pong | |
| class PongActor extends Actor { | |
| def receive = { | |
| case Ping ⇒ { | |
| println(self.path + ": Received Ping!") | |
| sender ! Pong |
| $ git clone git://github.com/ConnorDoyle/EnMAS-Quick-Start.git | |
| $ cd EnMAS-Quick-Start | |
| $ sbt update |
| $ git pull | |
| $ sbt update |
| $ java -jar enmas-server_2.10-1.0.0-assembly.jar |
This is an attempt to communicate unexpected behavior using the 2.1-SNAPSHOT version of Akka's cluster module.
Specifically, the unexpected behavior my application is experiencing is that when the cluster leader becomes unreachable due to a SIGINT, it is unable to re-join the cluster when restarted. Strangely, this always works when the node that is killed is not the leader.
| trait CakePosessor | |
| trait CakeConsumer | |
| class WhatYouWant extends CakePosessor with CakeConsumer |
| $ java -jar enmas-client_2.10-1.0.0-assembly.jar |
| $ g8 EnMAS/agent |
