patriknw

  case object Run
  case object Msg

  class Destination extends Actor {
    def receive = {
      case Msg ⇒ sender ! Msg
    }
  }

  class Client(

patriknw

package akka.config.bean

import java.util.{ List ⇒ JList }
import java.util.{ ArrayList ⇒ JArrayList }
import java.util.{ HashMap ⇒ JHashMap }
import scala.reflect.BeanProperty
import com.typesafe.config.Config
import com.typesafe.config.ConfigFactory

class AkkaConfigBean {

patriknw

package sample

import akka.actor.Actor
import akka.actor.Props
import akka.dispatch.Await
import akka.util.duration._
import akka.util.Timeout
import akka.actor.ActorRef
import akka.actor.Terminated
import akka.actor.ActorSystem

patriknw

package agent

import akka.agent.Agent
import akka.stm._

object AgentStmSample {

  def transfer(from: Agent[Int], to: Agent[Int], amount: Int): Boolean = {
    atomic {
      if (from.get < amount) false