I hereby claim:
- I am jboner on github.
- I am jonas (https://keybase.io/jonas) on keybase.
- I have a public key ASB-dCL3b2wk3TzgiVeoHmmp_s-ZM004MVmlztARjGu-pAo
To claim this, I am signing this object:
package demo | |
import akka.actor.{Props, ActorSystem} | |
import akka.persistence.PersistentActor | |
object PingPong extends App { | |
case object Ball // The Command | |
case object BallReceived // The Domain Event, represents a Fact, something that have already happened | |
class Ping extends PersistentActor { |
package demo | |
import akka.actor.{Actor, Props, ActorSystem} | |
object PingPong extends App { | |
case object Ball | |
class Ping extends Actor { | |
var counter = 0 |
import akka.actor.SupervisorStrategy._ | |
import akka.actor._ | |
import akka.persistence.PersistentActor | |
import scala.concurrent.duration._ | |
// Coffee types | |
trait CoffeeType | |
case object BlackCoffee extends CoffeeType | |
case object Latte extends CoffeeType | |
case object Espresso extends CoffeeType |
package com.earldouglas.remoteakka | |
import akka.actor.Actor | |
import akka.actor.Actor._ | |
case object Greeting | |
case class Jar(val bytes: Array[Byte]) | |
case class RegisterRemote(val name: String, val className: String) | |
object Runner { |
{ | |
"cmd": ["sbt-no-color compile"], | |
"file_regex": "^\\[error\\] ([.a-zA-Z0-9/-]+[.]scala):([0-9]+):", | |
"selector": "source.scala", | |
"working_dir": "${project_path:${folder}}", | |
"shell": "true" | |
} |
import se.scalablesolutions.akka.serialization.Serializer | |
import se.scalablesolutions.akka.actor.Actor | |
import com.rabbitmq.client.ConnectionParameters | |
object ExampleSession { | |
import AMQP._ | |
val SERIALIZER = Serializer.Java | |
val CONFIG = new ConnectionParameters | |
val HOSTNAME = "localhost" | |
val PORT = 5672 |
I hereby claim:
To claim this, I am signing this object:
lost(arg, function(err, result) { | |
if(err) return console.log(err); | |
In(result, function(err, result) { | |
if(err) return console.log(err); | |
callback(result, function(err, result) { | |
if(err) return console.log(err); | |
hell(result); | |
}); | |
}); | |
}); |
import akka.actor._ | |
import java.net.InetSocketAddress | |
import akka.util.ByteString | |
class SimpleClient(destAddress: InetSocketAddress) extends Actor { | |
val socket = IOManager(context.system) connect (destAddress) | |
val state = IO.IterateeRef.sync() |