patriknw

import akka.actor._

object MessageDiscarder {
  case object WorkerAvailable
}

class MessageDiscarder extends Actor {
  import MessageDiscarder._

  var queued: Option[(Any, ActorRef)] = None

patriknw

class MasterProxy extends Actor {
  // subscribe to LeaderChanged, re-subscribe when restart
  override def preStart(): Unit =
    Cluster(context.system).subscribe(self, classOf[LeaderChanged])
  override def postStop(): Unit =
    Cluster(context.system).unsubscribe(self)
 
  var leaderAddress: Option[Address] = None
 
  def receive = {

patriknw

system.actorOf(Props(new ClusterSingletonManager(
  singletonProps = handOverData => Props[Master]),
  singletonName = "master",
  terminationMessage = PoisonPill)),
  name = "singleton")

patriknw

Cluster(system) registerOnMemberUp {
  system.actorOf(Props(new FactorialFrontend(upToN, repeat = true)),
    name = "factorialFrontend")
}

patriknw

akka.cluster.min-nr-of-members = 3

patriknw

akka.actor.deployment {
  /factorialFrontend/factorialBackendRouter = {
    router = adaptive
    # metrics-selector = heap
    # metrics-selector = load
    # metrics-selector = cpu
    metrics-selector = mix
    nr-of-instances = 100
    cluster {
      enabled = on

patriknw

val backend = context.actorOf(Props[FactorialBackend].
  withRouter(FromConfig), name = "factorialBackendRouter")

patriknw

/**
 * Copyright (C) 2009-2013 Typesafe Inc. <http://www.typesafe.com>
 */

package akka.contrib.pattern

import scala.concurrent.duration._
import akka.actor.Actor
import akka.actor.Actor.Receive
import akka.actor.ActorLogging

patriknw

import akka.actor.{ Actor, ActorRef, Props, ActorSystem }
import akka.camel.{ CamelExtension, CamelMessage, Consumer, Producer }
import org.apache.activemq.camel.component.ActiveMQComponent

object CamelDemo extends App {
  val system = ActorSystem("CamelDemo")

  CamelExtension(system).context.addComponent("activemq",
    ActiveMQComponent.activeMQComponent(
      "vm://localhost?broker.persistent=false"))

patriknw

package example

import java.util.concurrent.ConcurrentHashMap
import java.util.concurrent.ConcurrentLinkedQueue
import com.typesafe.config.Config
import com.typesafe.config.ConfigFactory
import akka.actor.Actor
import akka.actor.ActorContext
import akka.actor.ActorRef
import akka.actor.ActorSystem