Merge branch 'master' of git@github.com:jboner/akka

akka-amqp/src/main/scala/AMQP.scala

@@ -1,3 +1,7 @@
+/**
+ * Copyright (C) 2009-2010 Scalable Solutions AB <http://scalablesolutions.se>
+ */
+
 package se.scalablesolutions.akka.amqp
 
 import se.scalablesolutions.akka.actor.{Actor, ActorRef}
@@ -69,6 +73,7 @@ object AMQP {
 
   def newConsumer(connection: ActorRef, consumerParameters: ConsumerParameters): ActorRef = {
     val consumer: ActorRef = actorOf(new ConsumerActor(consumerParameters))
+    consumer.startLink(consumerParameters.deliveryHandler)
     connection.startLink(consumer)
     consumer ! Start
     consumer

akka-amqp/src/main/scala/AMQPMessage.scala

@@ -1,3 +1,7 @@
+/**
+ * Copyright (C) 2009-2010 Scalable Solutions AB <http://scalablesolutions.se>
+ */
+
 package se.scalablesolutions.akka.amqp
 
 import se.scalablesolutions.akka.actor.ActorRef

akka-amqp/src/main/scala/ConsumerActor.scala

@@ -1,3 +1,7 @@
+/**
+ * Copyright (C) 2009-2010 Scalable Solutions AB <http://scalablesolutions.se>
+ */
+
 package se.scalablesolutions.akka.amqp
 
 import com.rabbitmq.client.AMQP.Queue.DeclareOk
@@ -24,10 +28,6 @@ private[amqp] class ConsumerActor(consumerParameters: ConsumerParameters) extend
 
   protected def setupChannel(ch: Channel) = {
 
-    // todo make nicer
-    if (!self.linkedActorsAsList.contains(deliveryHandler)) {
-      self.startLink(deliveryHandler)
-    }
     val queueDeclare: DeclareOk = {
       queueName match {
         case Some(name) =>

akka-amqp/src/main/scala/ExchangeType.scala

@@ -1,3 +1,7 @@
+/**
+ * Copyright (C) 2009-2010 Scalable Solutions AB <http://scalablesolutions.se>
+ */
+
 package se.scalablesolutions.akka.amqp
 
 sealed trait ExchangeType

akka-amqp/src/main/scala/FaultTolerantChannelActor.scala

@@ -1,3 +1,7 @@
+/**
+ * Copyright (C) 2009-2010 Scalable Solutions AB <http://scalablesolutions.se>
+ */
+
 package se.scalablesolutions.akka.amqp
 
 import collection.JavaConversions

akka-amqp/src/main/scala/FaultTolerantConnectionActor.scala

@@ -1,3 +1,7 @@
+/**
+ * Copyright (C) 2009-2010 Scalable Solutions AB <http://scalablesolutions.se>
+ */
+
 package se.scalablesolutions.akka.amqp
 
 import java.util.{TimerTask, Timer}
@@ -40,7 +44,6 @@ private[amqp] class FaultTolerantConnectionActor(connectionParameters: Connectio
       }
     }
     case ConnectionShutdown(cause) => {
-      disconnect
       if (cause.isHardError) {
         // connection error
         if (cause.isInitiatedByApplication) {

akka-amqp/src/main/scala/ProducerActor.scala

@@ -1,3 +1,7 @@
+/**
+ * Copyright (C) 2009-2010 Scalable Solutions AB <http://scalablesolutions.se>
+ */
+
 package se.scalablesolutions.akka.amqp
 
 import com.rabbitmq.client._

akka-amqp/src/test/scala/AMQPConnectionRecoveryTest.scala

@@ -1,3 +1,7 @@
+/**
+ * Copyright (C) 2009-2010 Scalable Solutions AB <http://scalablesolutions.se>
+ */
+
 package se.scalablesolutions.akka.amqp.test
 
 import se.scalablesolutions.akka.util.Logging
@@ -12,7 +16,7 @@ import se.scalablesolutions.akka.amqp.AMQP.ConnectionParameters
 import org.scalatest.matchers.MustMatchers
 
 class AMQPConnectionRecoveryTest extends JUnitSuite with MustMatchers with Logging {
-  
+
 //  @Test
   def connectionAndRecovery = {
     val connectedLatch = new StandardLatch
@@ -44,4 +48,11 @@ class AMQPConnectionRecoveryTest extends JUnitSuite with MustMatchers with Loggi
       disconnectedLatch.tryAwait(2, TimeUnit.SECONDS) must be(true)
     }
   }
+
+  @Test
+  def dummy {
+    // amqp tests need local rabbitmq server running, so a disabled by default.
+    // this dummy test makes sure that the whole test class doesn't fail because of missing tests
+    assert(true)
+  }
 }

akka-amqp/src/test/scala/AMQPConsumerChannelRecoveryTest.scala

@@ -1,3 +1,7 @@
+/**
+ * Copyright (C) 2009-2010 Scalable Solutions AB <http://scalablesolutions.se>
+ */
+
 package se.scalablesolutions.akka.amqp.test
 
 import se.scalablesolutions.akka.util.Logging
@@ -55,4 +59,11 @@ class AMQPConsumerChannelRecoveryTest extends JUnitSuite with MustMatchers with
       connection.stop
     }
   }
+
+  @Test
+  def dummy {
+    // amqp tests need local rabbitmq server running, so a disabled by default.
+    // this dummy test makes sure that the whole test class doesn't fail because of missing tests
+    assert(true)
+  }
 }

akka-amqp/src/test/scala/AMQPConsumerConnectionRecoveryTest.scala

@@ -1,3 +1,7 @@
+/**
+ * Copyright (C) 2009-2010 Scalable Solutions AB <http://scalablesolutions.se>
+ */
+
 package se.scalablesolutions.akka.amqp.test
 
 import se.scalablesolutions.akka.util.Logging
@@ -73,4 +77,11 @@ class AMQPConsumerConnectionRecoveryTest extends JUnitSuite with MustMatchers wi
       connection.stop
     }
   }
+
+  @Test
+  def dummy {
+    // amqp tests need local rabbitmq server running, so a disabled by default.
+    // this dummy test makes sure that the whole test class doesn't fail because of missing tests
+    assert(true)
+  }
 }

akka-amqp/src/test/scala/AMQPConsumerManualAcknowledgeTest.scala

@@ -1,3 +1,7 @@
+/**
+ * Copyright (C) 2009-2010 Scalable Solutions AB <http://scalablesolutions.se>
+ */
+
 package se.scalablesolutions.akka.amqp.test
 
 import se.scalablesolutions.akka.util.Logging
@@ -44,4 +48,11 @@ class AMQPConsumerManualAcknowledgeTest extends JUnitSuite with MustMatchers wit
       connection.stop
     }
   }
+
+  @Test
+  def dummy {
+    // amqp tests need local rabbitmq server running, so a disabled by default.
+    // this dummy test makes sure that the whole test class doesn't fail because of missing tests
+    assert(true)
+  }
 }

akka-amqp/src/test/scala/AMQPConsumerMessageTest.scala

@@ -1,3 +1,7 @@
+/**
+ * Copyright (C) 2009-2010 Scalable Solutions AB <http://scalablesolutions.se>
+ */
+
 package se.scalablesolutions.akka.amqp.test
 
 import se.scalablesolutions.akka.util.Logging
@@ -39,4 +43,11 @@ class AMQPConsumerMessageTest extends JUnitSuite with MustMatchers with Logging
       connection.stop
     }
   }
+
+  @Test
+  def dummy {
+    // amqp tests need local rabbitmq server running, so a disabled by default.
+    // this dummy test makes sure that the whole test class doesn't fail because of missing tests
+    assert(true)
+  }
 }

akka-amqp/src/test/scala/AMQPProducerChannelRecoveryTest.scala

@@ -1,3 +1,7 @@
+/**
+ * Copyright (C) 2009-2010 Scalable Solutions AB <http://scalablesolutions.se>
+ */
+
 package se.scalablesolutions.akka.amqp.test
 
 import se.scalablesolutions.akka.util.Logging
@@ -49,4 +53,11 @@ class AMQPProducerChannelRecoveryTest extends JUnitSuite with MustMatchers with
       connection.stop
     }
   }
+
+  @Test
+  def dummy {
+    // amqp tests need local rabbitmq server running, so a disabled by default.
+    // this dummy test makes sure that the whole test class doesn't fail because of missing tests
+    assert(true)
+  }
 }

akka-amqp/src/test/scala/AMQPProducerConnectionRecoveryTest.scala

@@ -1,3 +1,7 @@
+/**
+ * Copyright (C) 2009-2010 Scalable Solutions AB <http://scalablesolutions.se>
+ */
+
 package se.scalablesolutions.akka.amqp.test
 
 import se.scalablesolutions.akka.util.Logging
@@ -47,4 +51,11 @@ class AMQPProducerConnectionRecoveryTest extends JUnitSuite with MustMatchers wi
       connection.stop
     }
   }
+
+  @Test
+  def dummy {
+    // amqp tests need local rabbitmq server running, so a disabled by default.
+    // this dummy test makes sure that the whole test class doesn't fail because of missing tests
+    assert(true)
+  }
 }

akka-amqp/src/test/scala/AMQPProducerMessageTest.scala

@@ -1,3 +1,7 @@
+/**
+ * Copyright (C) 2009-2010 Scalable Solutions AB <http://scalablesolutions.se>
+ */
+
 package se.scalablesolutions.akka.amqp.test
 
 import se.scalablesolutions.akka.util.Logging
@@ -38,4 +42,11 @@ class AMQPProducerMessageTest extends JUnitSuite with MustMatchers with Logging
       connection.stop
     }
   }
+
+  @Test
+  def dummy {
+    // amqp tests need local rabbitmq server running, so a disabled by default.
+    // this dummy test makes sure that the whole test class doesn't fail because of missing tests
+    assert(true)
+  }
 }