jboner

case class MyMessage(val id: String, val value: Tuple2[String, Int]) extends ScalaJSON
val message = MyMessage("id", ("hello", 34))

val json = message.toJSON
val messageCopy = Serializer.ScalaJSON.in(json)

jboner

import akka.actor._
import akka.actor.SupervisorStrategy._
import scala.concurrent.duration._

// Coffee types
trait CoffeeType
case object BlackCoffee extends CoffeeType
case object Latte extends CoffeeType
case object Espresso extends CoffeeType

jboner

jboner at sarek in ~/src/akka-stuff/akka on master
[130] $ cloc .                                                                                                                                                           5244 text files.
    2647 unique files.                                          
    3822 files ignored.

http://cloc.sourceforge.net v 1.56  T=52.0 s (41.8 files/s, 13040.5 lines/s)
--------------------------------------------------------------------------------
Language                      files          blank        comment           code
--------------------------------------------------------------------------------
HTML                           1473          39655              1         529371

jboner

import scala.collection.mutable.ListBuffer
import akka.actor.{Actor,ActorRef}
import akka.actor.Actor._
import akka.routing.{ Listeners, Listen }

//Represents a domain event
trait Event

//A builder to create domain entities
trait EntityBuilder[Entity] {

jboner

// Shutdown HawtDispatch GlobalQueue
org.fusesource.hawtdispatch.ScalaDispatch.globalQueue.asInstanceOf[org.fusesource.hawtdispatch.internal.GlobalDispatchQueue].shutdown

// Clear Thread.subclassAudits
val tf = classOf[java.lang.Thread].getDeclaredField("subclassAudits")
tf.setAccessible(true)
val subclassAudits = tf.get(null).asInstanceOf[java.util.Map[_,_]]
subclassAudits.synchronized {subclassAudits.clear}

// Clear and reset j.u.l.Level.known (due to Configgy)

jboner

import java.util.zip._
import java.io._

class InMemZip(compressionLevel: Int) {
  private val _outBytes = new ByteArrayOutputStream
  private val _zipOutStream = {
    val s = new ZipOutputStream(_outBytes)
    s.setLevel(compressionLevel)
    s
  }

jboner

<!-- Example of Akka/Spring integration --> 

<beans>
  <!-- Create an active object -->
  <akka:active-object id="myActiveObject" 
                      target="com.biz.MyPOJO" 
                      transactional="true" 
                      timeout="1000" />

jboner

import java.io.{BufferedReader, File, InputStream, InputStreamReader, IOException, PrintWriter, Writer}
import java.net.{InetAddress, ServerSocket, Socket, SocketException}
import java.util.concurrent.Executors
import net.lag.logging.Logger
import scala.actors.Actor
import scala.actors.Actor._
import scala.tools.nsc._


class RemoteDebugServer(port: Int) {

jboner

import com.facebook.thrift.{TBase, TDeserializer}
import java.io.{BufferedInputStream, DataInputStream, File, FileInputStream, InputStream}
import java.util.zip.GZIPInputStream
import net.lag.logging.Logger
import scala.reflect.Manifest
// you'll want to import your generated Thrift package too!

class ThriftFileScanner[T <: TBase](implicit man: Manifest[T]) {
  val log = Logger.get
  var bufferedIn: BufferedInputStream = null

jboner

/**
 * Base trait for all classes that wants to be able use the logging infrastructure.
 * 
 * @author <a href="http://jonasboner.com">Jonas Bon&#233;r</a>
 */
trait Logging {
  @transient var log = Logger.get(this.getClass.getName)
}

/**