stephanos

NetBeans: Executing 'D:\work\dev\tools\maven3\bin\mvn.bat -Dnetbeans.execution=true --debug --debug clean install'
NetBeans:      JAVA_HOME=D:\Applications\Java\jdk1.6.0_17
Apache Maven 3.0-beta-1 (r935667; 2010-04-19 19:00:39+0200)
Java version: 1.6.0_17
Java home: D:\Applications\Java\jdk1.6.0_17\jre
Default locale: de_DE, platform encoding: Cp1252
OS name: "windows 7" version: "6.1" arch: "x86" Family: "windows"
Error stacktraces are turned on.
[DEBUG]Reading user settings from D:\work\.m2\settings.xml
[DEBUG]Reading global settings from D:\work\dev\tools\maven3\conf\settings.xml

stephanos

import scala.reflect.BeanInfo
import se.scalablesolutions.akka.amqp._
import sjson.json.Serializer
import se.scalablesolutions.akka.amqp.AMQP._
import se.scalablesolutions.akka.actor._

/**
 * An attempt to make the communication over AMQP sort of 'type-safe'.
 *
 * - The producer and the consumer have been merged to one 'messenger' which is connected with a 'routing key parent'

stephanos

object AMQPTest extends Logging {

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

    class JobConsumer extends Actor {

        def receive = {
            case Delivery(payload, _, _, _, _, _) =>
                println("Received message: " + new String(payload))

stephanos

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

object AMQPTest extends Logging {

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

stephanos

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

object AMQPTest extends Logging {

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

stephanos

    private def shrinkDBO(dbo: DBObject): DBObject = {
        def isDBO(v: AnyRef) = v.isInstanceOf[DBObject]
        def isEmptyDBO(v: AnyRef) = isDBO(v) && v.asInstanceOf[DBObject].isEmpty
        def shrink(v: AnyRef) = if (isDBO(v)) shrinkDBO(v.asInstanceOf[DBObject]) else v

        dbo match {
            case _: BasicDBList =>
                val ls = new BasicDBList()
                (dbo.mapValues(shrink(_)).filter(!isEmptyDBO(_)).values).foreach(ls.add(_))
                ls

stephanos

<table>
    <tbody>
    
        <!-- first 'section' -->
        <tr class="head">
            <td>HEAD A</td>
            <td></td>
        </tr>
        
        <tr class="data">

stephanos

<table>
    <tbody>

        <!-- first 'section' -->
        <tr class="head">
            <td colspan="4">HEAD A</td>
        </tr>

        <tr class="data">
            <td>a</td>

stephanos

import org.slf4j._
lazy val log = LoggerFactory.getLogger(loggerName)

Session.currentSession.setLogger(logging(_))

def logging(msg: String) {

    if (log.isDebugEnabled) {

        val _m = msg.replaceAll("\n", " ").replaceAll("  ", " ").replaceAll("  ", " ")

stephanos

#logs
*.log
logs/
logs/**
tmp/
tmp/**

#assets
*.ai
*.psd