tjweir

package sample


import akka.actor._
import akka.http._

class SampleService extends Actor with Endpoint
{
  self.dispatcher = Endpoint.Dispatcher;

tjweir

/**
 * Copyright Kazuo KASHIMA 2011
 * k4200 [at] kazu [dot] tv
 * Licensed under the same license as Lift framework (Apache 2.0)
 */

package code.model

import net.liftweb._
import mapper._

tjweir

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE plist PUBLIC "-//Apple//DTD PLIST 1.0//EN" "http://www.apple.com/DTDs/PropertyList-1.0.dtd">
<plist version="1.0">
<dict>
  <key>Label</key>
  <string>org.mongodb.mongod</string>
  <key>ProgramArguments</key>
  <array>
    <string>/usr/local/mongodb/bin/mongod</string>
    <string>run</string>

tjweir

import akka.amqp.AMQP._
import akka.amqp._
import akka.actor._
import akka.util.Logging

object LoadBalancingTest extends Logging {

    val connection = AMQP.newConnection()
    val exchangeParameters = ExchangeParameters("my_direct_exchange", Direct)

tjweir

import scalaz._

/**
 * playing with some of the ideas from the Haskell fclabels library
 * using the new Lens functionality in scalaz
 * 
 * http://hackage.haskell.org/package/fclabels
 */
object LensTest {

tjweir

import scalaz._,Scalaz._

import akka.scalaz.futures._
import akka.dispatch._

import System.{currentTimeMillis => now}

object Pi extends App {
  val nrOfElements = 10000
  val nrOfMessages = 10000

tjweir

class Aggregator(recipients: Iterable[ActorRef]) extends Actor{
    
  def receive = {
    case msg @ Message(text) => 
      println("Started processing message `%s`" format(text))
      
      val result = Promise[String]()          
      val promises = List.fill(recipients.size)(Promise[String]())
      
      recipients.zip(promises).map{case (recipient, promise) =>

tjweir

val test = j_var ("test") := j_true
val test2 = j_var ('test2) := j_false

1 j_< 2
JsVar("k") j_<= 10

val a: JsVar = 'a
a++

val clause1 = j_if (j_true) {

tjweir

require 'zmq'
context = ZMQ::Context.new
pub = context.socket ZMQ::PUB
pub.setsockopt ZMQ::IDENTITY, 'ping-pinger'
pub.bind 'tcp://*:5555'

i=0
loop do
  pub.send "ping pinger #{i+=1}" ; sleep 1
end

tjweir

class A
class A2 extends A
class B

trait M[X]

//
// Upper Type Bound
//
def upperTypeBound[AA <: A](x: AA): A = x