momania

package actor.actor

import akka.actor.{Actor, FSM}
import java.util.concurrent.TimeUnit

sealed trait ExampleState
case object A extends ExampleState
case object B extends ExampleState
case object C extends ExampleState

momania

import akka.amqp.AMQP.{ToBinary, FromBinary}
import rpc.RPC.{RpcClientSerializer, RpcServerSerializer}
import rpc.RPC
import akka.actor.ActorRegistry

object RPCExample {

  def main(args: Array[String]) {
    // shared between client and server
    val connection = AMQP.newConnection()

momania

class GotoFsm extends Actor with FSM[Int, Null] {

  notifying {
    case Transition(_, 10) => println("Goto 10 ftw!")
  }

  when(0) {
    case _ => goto(10) until 5000
  }

momania

import akka.actor.{Actor, FSM}
import java.util.concurrent.TimeUnit

sealed trait Health
case object Stale extends Health
case object Alive extends Health
case object Dead extends Health

case object HeartBeat