Akka producer actors best practices - Part 1

CamelContextManager.scala

CamelContextManager.init
CamelContextManager.start

HttpProducer.scala

import akka.actor._
import akka.camel._

class HttpProducer extends Actor with Producer {
  def endpointUri = "jetty:http://localhost:8080/test"
}

HttpProducerClientBang.scala

implicit val sender: Option[ActorRef] = ...

httpProducer ! "test"

HttpProducerClientBangBang.scala

val httpProducer = Actor.actorOf[HttpProducer].start

httpProducer !! "test" match {
  case Some(Message(body, headers)) => println("body = %s, headers = %s" format (body, headers))
  case _ => ...
}

HttpProducerClientFailure.scala

httpProducer !! "test" match {
  case Some(Message(body, headers))   => println("body = %s, headers = %s" format (body, headers))
  case Some(Failure(cause, headers))  => println("failure cause = %s, headers = %s" format (cause, headers))
  case None                           => println("timeout")
}

JmsProducer.scala

class JmsProducer extends Actor with Producer {
  def endpointUri = "jms:queue:test"
  override def oneway = true
}

JmsReplyingProducer.scala

class JmsReplyingProducer extends Actor with Producer {
  def endpointUri = "jms:queue:test"
  override def oneway = true
  override def receiveAfterProduce = {
    case _ => self.reply("done")
  }
}

JmsReplyingProducerFailure.scala

class JmsReplyingProducer extends Actor with Producer {
  def endpointUri = "jms:queue:test"
  override def oneway = true
  override def receiveAfterProduce = {
    case message: Message => self.reply("done")
    case failure: Failure => self.reply("message could not be added to queue: %s" format failure.cause.getMessage)
  }
}

ReceiveAfterProduceDefault.scala

trait Producer {
  // ...

  protected def receiveAfterProduce: Receive = {
    case msg => if (!oneway) self.reply(msg)
  }

  // ...
}

SomeProducer.scala

class SomeProducer extends Actor with Producer {
  // ...
  override def receiveAfterProduce = {
    case Failure(cause, _) => throw cause
    // ...   
  }
}