Skip to content

Instantly share code, notes, and snippets.

View sstone's full-sized avatar

Fabrice Drouin sstone

  • ACINQ
  • Paris, France
View GitHub Profile
@sstone
sstone / gist:3418490
Created August 21, 2012 19:21
calculator actor
case class AddRequest(x:Int, y:Int)
case class AddResponse(sum:Int)
class Calculator extends Actor {
protected def receive = {
case AddRequest(a, b) => sender ! AddResponse(a + b)
}
}
@sstone
sstone / gist:3338510
Created August 13, 2012 09:07
Akka AMQP proxies
package com.aphelia
import akka.actor.{Actor, ActorRef}
import akka.pattern.ask
import akka.serialization.Serializer
import amqp.Amqp.{Publish, Delivery}
import amqp.{RpcClient, RpcServer}
import amqp.RpcServer.ProcessResult
import com.rabbitmq.client.AMQP.BasicProperties
import akka.dispatch.{Future, Await}