krasserm

// ###########################################################
//
//  Demonstrates how to supervise an Akka consumer actor.
//
//  The consumer consumes messages from a file endpoint:
//  - successful message processing by the consumer will
//    positively acknowledge the message receipt, causing
//    the file endpoint to delete the file.
//  - an exception during message processing will cause a
//    supervisor to restart the consumer. Before restart,

krasserm

import scalaz._
import Scalaz._
import scalaz.concurrent._

/**
 * Result type of concurrent functions that may fail.
 */
case class PromiseEither[A, B](value: Promise[Either[A, B]]) extends NewType[Promise[Either[A, B]]]

/**

krasserm

httpProducer ! Message("test", Map(Message.MessageExchangeId -> 123))

krasserm

CamelContextManager.init
CamelContextManager.start

krasserm

Index: project/build/Project.scala
===================================================================
--- project/build/Project.scala	(date 1302329914000)
+++ project/build/Project.scala	(revision )
@@ -3,9 +3,9 @@
 class Project(info: ProjectInfo) extends DefaultProject(info) with IdeaProject with AkkaProject {
   val ScalazVersion = "5.0"
   val CamelVersion = "2.7.0"
-  val AkkaVersion = "1.1-M1"
+  val AkkaVersion = "1.0"

krasserm

import org.apache.http.client.methods.HttpPost
import org.apache.http.client.params.ClientPNames._
import org.apache.http.client.HttpClient
import org.apache.http.entity.StringEntity
// other imports omitted ...

object GCAuthExample {

  def main(args:Array[String]) {

krasserm

case class InvoiceAddress(street: String, city: String, country: String)
case class InvoiceItem(description: String, count: Int, amount: BigDecimal)

case class Invoice(
    id: String,
    items: List[InvoiceItem] = Nil,
    discount: Option[BigDecimal] = None,
    sentTo: Option[InvoiceAddress] = None) extends EventSourced[InvoiceEvent, Invoice] {

  def addItem(item: InvoiceItem): Update[InvoiceEvent, Invoice] = ...

krasserm

class InvoiceService {
  val invoicesRef = Ref(Map.empty[String, Invoice]) // naive approach

  // ...
}

krasserm

import akka.actor._
import akka.dispatch._
import akka.stm._
import scalaz._

trait Projection[S, A] {
  def initialState: S
  def currentState: S

  def project: PartialFunction[(S, A), S]

krasserm

import javax.xml.bind.annotation._

@XmlRootElement(name = "person")
@XmlAccessorType(XmlAccessType.FIELD)
case class Person(fullname: String, username: Option[String], age: Int)