- add possibility to specify channel prefetch side for consumer

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

@@ -60,7 +60,8 @@ object AMQP {
    */
   case class ChannelParameters(
           shutdownListener: Option[ShutdownListener] = None,
-          channelCallback: Option[ActorRef] = None) {
+          channelCallback: Option[ActorRef] = None,
+          prefetchSize: Int = 0) {
 
     // Needed for Java API usage
     def this() = this (None, None)

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

@@ -30,6 +30,8 @@ private[amqp] class ConsumerActor(consumerParameters: ConsumerParameters)
 
   protected def setupChannel(ch: Channel) = {
 
+    channelParameters.foreach(params => ch.basicQos(params.prefetchSize))
+    
     val exchangeName = exchangeParameters.flatMap(params => Some(params.exchangeName))
     val consumingQueue = exchangeName match {
       case Some(exchange) =>