patriknw

package example

import java.util.concurrent.ConcurrentHashMap
import java.util.concurrent.ConcurrentLinkedQueue
import com.typesafe.config.Config
import com.typesafe.config.ConfigFactory
import akka.actor.Actor
import akka.actor.ActorContext
import akka.actor.ActorRef
import akka.actor.ActorSystem

danieltreacy

Tech companies who have migrated to the JVM

NB: Does not include companies that started with a JVM language. The purpose of this gist is to list the companies that decided to move their stack (or some part of it) to the JVM.

• Twitter (Ruby -> Scala) - http://www.readwriteweb.com/hack/2011/07/twitter-java-scala.php
• Foursquare (PHP -> Scala) - http://www.scala-lang.org/node/5130
• Facebook (PHP/C++ -> PHP on JVM) - http://nerds-central.blogspot.com.au/2012/08/facebook-moving-to-jvm.html
• Tumblr (PHP -> Scala) - http://highscalability.com/blog/2012/2/13/tumblr-architecture-15-billion-page-views-a-month-and-harder.html
• Square (Ruby -> Java/JRuby) - http://www.quora.com/Square-Inc-1/What-is-the-technology-stack-behind-Square

adamretter

def withConnection[T](ds: ComboPooledDataSource, fn : Connection => T) : T = {

    var optConn : Option[Connection] = Option.empty;
    try {
      val conn = ds.getConnection
      optConn = Some(conn);

      fn(conn)

    } finally {

gseitz

package akka.actor

import collection.mutable
import akka.actor.FSM.{ CurrentState, Transition, UnsubscribeTransitionCallBack, SubscribeTransitionCallBack }
import akka.routing.{ Deafen, Listen }

case object PreRestart
case object PostRestart

trait ParentNotification { thisActor: Actor ⇒

daggerrz

import java.io.RandomAccessFile
import java.nio.channels.FileChannel
import org.jboss.netty.buffer.{ByteBufferBackedChannelBuffer, ChannelBuffer, ChannelBuffers}

/**
 * Maps a the filename to a memory mapped random access file across 1 or more buffers.
 * Support files up to Long.MAX_VALUE.
 *
 * @param filename the file to map
 * @param maxBufferSize the maximum number of bytes to map per buffer

gclaramunt

trait FlightStatus
trait Flying extends FlightStatus
trait Landed extends FlightStatus

case class Plane[Status <: FlightStatus]()

def land(p:Plane[Flying])=Plane[Landed]()
def takeOff(p:Plane[Landed])= Plane[Flying]()

val plane = new Plane[Landed]()

joergviola

public class Global extends GlobalSettings {

	@Override
	public Action onRequest(Request arg0, Method arg1) {
		return new Action.Simple() {
			public Result call(Context ctx) throws Throwable {
				String authConf = Config.getString("basic.auth");
				if (authConf == null)
					return delegate.call(ctx);
				String auth = ctx.request().getHeader("Authorization");

stonegao

import akka.actor.Actor
import akka.actor.ActorSystem
import akka.agent.Agent
import com.typesafe.config.ConfigFactory
import akka.event.Logging
import akka.actor.Props
import kafka.utils.Utils
import java.nio.ByteBuffer

fcroiseaux

  /**
   * Handles the comet event stream.
   */
  def cometStream = Action {
    AsyncResult {
      implicit val timeout = Timeout(5.seconds)
      val actor=Akka.system.actorOf(Props[EventListener])
      // Actor is listening for event on the eventStream
      Akka.system.eventStream.subscribe(actor,classOf[ChangeEvent])
      // For each event, stream the data to client

viktorklang

/*
Copyright 2012-2021 Viktor Klang
 
   Licensed under the Apache License, Version 2.0 (the "License");
   you may not use this file except in compliance with the License.
   You may obtain a copy of the License at
 
       http://www.apache.org/licenses/LICENSE-2.0
 
   Unless required by applicable law or agreed to in writing, software