revert setting PrefetchSize as it is not supported by RabbitMQ

DeonHeyns · DeonHeyns · commit e1f60f8ed64f · 2018-06-25T19:03:39.000-03:00
diff --git a/src/ServiceStack.RabbitMq/RabbitMqProducer.cs b/src/ServiceStack.RabbitMq/RabbitMqProducer.cs
@@ -17,8 +17,7 @@ public class RabbitMqProducer : IMessageProducer, IOneWayClient
         public Action<string, BasicGetResult> GetMessageFilter { get; set; }
         //http://www.rabbitmq.com/blog/2012/04/25/rabbitmq-performance-measurements-part-2/
         //http://www.rabbitmq.com/amqp-0-9-1-reference.html
-        public uint PrefetchCount { get; set; } = 20;
-        public ushort PrefetchSize { get; set; } = 0;
+        public ushort PrefetchCount { get; set; } = 20;
 
         private IConnection connection;
         public IConnection Connection
@@ -41,7 +40,9 @@ public IModel Channel
                 if (channel == null || !channel.IsOpen)
                 {
                     channel = Connection.OpenChannel();
-                    channel.BasicQos(PrefetchCount, PrefetchSize, global: false);
+                    //prefetch size is no supported by RabbitMQ
+                    //http://www.rabbitmq.com/specification.html#method-status-basic.qos
+                    channel.BasicQos(prefetchSize: 0, prefetchCount: PrefetchCount, global: false);
                 }
                 return channel;
             }

Original file line number	Diff line number	Diff line change
`@@ -17,8 +17,7 @@ public class RabbitMqProducer : IMessageProducer, IOneWayClient`
`17`	`17`	`public Action<string, BasicGetResult> GetMessageFilter { get; set; }`
`18`	`18`	`//http://www.rabbitmq.com/blog/2012/04/25/rabbitmq-performance-measurements-part-2/`
`19`	`19`	`//http://www.rabbitmq.com/amqp-0-9-1-reference.html`
`20`		`- public uint PrefetchCount { get; set; } = 20;`
`21`		`- public ushort PrefetchSize { get; set; } = 0;`
	`20`	`+ public ushort PrefetchCount { get; set; } = 20;`
`22`	`21`
`23`	`22`	`private IConnection connection;`
`24`	`23`	`public IConnection Connection`
`@@ -41,7 +40,9 @@ public IModel Channel`
`41`	`40`	`if (channel == null \|\| !channel.IsOpen)`
`42`	`41`	`{`
`43`	`42`	`channel = Connection.OpenChannel();`
`44`		`- channel.BasicQos(PrefetchCount, PrefetchSize, global: false);`
	`43`	`+ //prefetch size is no supported by RabbitMQ`
	`44`	`+ //http://www.rabbitmq.com/specification.html#method-status-basic.qos`
	`45`	`+ channel.BasicQos(prefetchSize: 0, prefetchCount: PrefetchCount, global: false);`
`45`	`46`	`}`
`46`	`47`	`return channel;`
`47`	`48`	`}`