krasserm

class BoundedMailboxDirectConsumer extends Actor with Consumer {
  import akka.dispatch._
  import akka.util.duration._

  // Create a bounded mailbox for this consumer actor with a capacity of 10
  self.dispatcher = Dispatchers.newThreadBasedDispatcher(self, 5, 100.milliseconds)

  // instruct how the route should be customized during route creation (definition)
  onRouteDefinition { rd: RouteDefinition =>
    // on exception attempt max 3 redeliveries with a delay of 1000 ms

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

CamelContextManager.init
CamelContextManager.start

krasserm

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

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

import scalaz._
import Scalaz._

object MonadTransformerExamples {
  def main(args: Array[String]) = run

  def run {
    // ------------------------------------------------------
    // Combined Option/Option
    // ------------------------------------------------------

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]