From 09d7cc75eb3c2b45735f29fdaa12bbd1c77d1d08 Mon Sep 17 00:00:00 2001
From: momania <irmo.manie@gmail.com>
Date: Fri, 6 Aug 2010 13:39:24 +0200
Subject: [PATCH] - forgot the api commit - disable tests again :S

---
 akka-amqp/src/main/scala/AMQP.scala     | 6 ++++--
 akka-amqp/src/test/scala/AMQPTest.scala | 2 +-
 2 files changed, 5 insertions(+), 3 deletions(-)

diff --git a/akka-amqp/src/main/scala/AMQP.scala b/akka-amqp/src/main/scala/AMQP.scala
index 0bfbd93063..b1e08ae752 100644
--- a/akka-amqp/src/main/scala/AMQP.scala
+++ b/akka-amqp/src/main/scala/AMQP.scala
@@ -95,13 +95,15 @@ object AMQP {
                    exchangeParameters: ExchangeParameters,
                    routingKey: String,
                    serializer: RpcServerSerializer[I,O],
-                   requestHandler: PartialFunction[I, O],
+                   requestHandler: I => O,
+                   queueName: Option[String] = None,
                    channelParameters: Option[ChannelParameters] = None) = {
     val producer = newProducer(connection, new ProducerParameters(new ExchangeParameters("", ExchangeType.Direct), channelParameters = channelParameters))
     val rpcServer = actorOf(new RpcServerActor[I,O](producer, serializer, requestHandler))
     val consumer = newConsumer(connection, new ConsumerParameters(exchangeParameters, routingKey, rpcServer
       , channelParameters = channelParameters
-      , selfAcknowledging = false))
+      , selfAcknowledging = false
+      , queueName = queueName))
 
   }
 
diff --git a/akka-amqp/src/test/scala/AMQPTest.scala b/akka-amqp/src/test/scala/AMQPTest.scala
index 8cad27ba60..5ff9157bc5 100644
--- a/akka-amqp/src/test/scala/AMQPTest.scala
+++ b/akka-amqp/src/test/scala/AMQPTest.scala
@@ -5,5 +5,5 @@
 package se.scalablesolutions.akka.amqp.test
 
 object AMQPTest {
-  def enabled = true
+  def enabled = false
 }