Version: 1.1.14 (#7)

* Added a simple ConfigurationSection for use in appsettings.json

* Using the new section in one of the examples.

Author: rwindegger

Examples/RabbitExpress.Example.RpcClient/Program.cs

@@ -39,11 +39,13 @@ namespace RabbitExpress.Example.RpcClient
     /// </summary>
     internal class Program
     {
-        private static IConfiguration _configuration;
+        private static IConfigurationRoot _configuration;
 
         private static async Task Test()
         {
-            using (var qc = new QueueClient<MsgPackSerializer>(new Uri(_configuration["RabbitExpressConnection"])))
+            var qConfig = new QueueConfig();
+            _configuration.GetSection("RabbitExpress").Bind(qConfig);
+            using (var qc = new QueueClient<MsgPackSerializer>(qConfig))
             {
                 IExampleService client = qc.RpcClient<IExampleService>();
                 Console.WriteLine(client.Calculate(2, 4));

Examples/RabbitExpress.Example.RpcClient/RabbitExpress.Example.RpcClient.csproj

@@ -8,6 +8,7 @@
 
 	<ItemGroup>
 		<PackageReference Include="Microsoft.Extensions.Configuration" Version="2.2.0" />
+		<PackageReference Include="Microsoft.Extensions.Configuration.Binder" Version="2.2.4" />
 		<PackageReference Include="Microsoft.Extensions.Configuration.EnvironmentVariables" Version="2.2.4" />
 		<PackageReference Include="Microsoft.Extensions.Configuration.FileExtensions" Version="2.2.0" />
 		<PackageReference Include="Microsoft.Extensions.Configuration.Json" Version="2.2.0" />

Examples/RabbitExpress.Example.RpcClient/appsettings.json

@@ -1,3 +1,6 @@
 {
-	"RabbitExpressConnection": "[connectionString]"
+	"RabbitExpress": {
+		"ConnectionString": "[connectionString]",
+		"PrefetchSize": 1
+	}
 }

RabbitExpress/QueueClient.cs

@@ -28,6 +28,7 @@
 // ***********************************************************************
 namespace RabbitExpress
 {
+    using Microsoft.Extensions.Options;
     using MsgPack.Serialization;
     using RabbitMQ.Client;
     using RabbitMQ.Client.Events;
@@ -209,14 +210,42 @@ private void RegisterQueues<TInterface>()
         /// </summary>
         /// <param name="connectionString">The connection string.</param>
         public QueueClient(Uri connectionString)
+            : this(new ConnectionFactory() { Uri = connectionString, DispatchConsumersAsync = true })
         {
             var factory = new ConnectionFactory()
             {
                 Uri = connectionString,
                 DispatchConsumersAsync = true
             };
+        }
 
-            _connection = factory.CreateConnection();
+        /// <summary>
+        /// Initializes a new instance of the <see cref="QueueClient{TSerializer}"/> class.
+        /// </summary>
+        /// <param name="config">The connection setting.</param>
+        public QueueClient(IOptions<QueueConfig> config)
+            : this(config.Value.ConnectionString)
+        {
+            _model.BasicQos(0, config.Value.PrefetchSize, false);
+        }
+
+        /// <summary>
+        /// Initializes a new instance of the <see cref="QueueClient{TSerializer}"/> class.
+        /// </summary>
+        /// <param name="config">The connection setting.</param>
+        public QueueClient(QueueConfig config)
+            : this(config.ConnectionString)
+        {
+            _model.BasicQos(0, config.PrefetchSize, false);
+        }
+
+        /// <summary>
+        /// Initializes a new instance of the <see cref="QueueClient{TSerializer}"/> class.
+        /// </summary>
+        /// <param name="connectionFactory">The connection factory used to create the connection.</param>
+        public QueueClient(IConnectionFactory connectionFactory)
+        {
+            _connection = connectionFactory.CreateConnection();
             _model = _connection.CreateModel();
 
             _consumer = new AsyncEventingBasicConsumer(_model);

RabbitExpress/QueueConfig.cs

@@ -0,0 +1,38 @@
+// ***********************************************************************
+// Assembly         : RabbitExpress
+// Author           : Rene Windegger
+// Created          : 06-06-2019
+//
+// Last Modified By : Rene Windegger
+// Last Modified On : 06-06-2019
+// ***********************************************************************
+// <copyright file="QueueConfig.cs" company="Rene Windegger">
+//     Copyright (c) Rene Windegger. All rights reserved.
+// </copyright>
+// <summary>
+// This file is part of RabbitExpress.
+//
+// RabbitExpress is free software: you can redistribute it and/or modify
+// it under the terms of the GNU Lesser General Public License as published by
+// the Free Software Foundation, either version 3 of the License, or
+// (at your option) any later version.
+//
+// RabbitExpress is distributed in the hope that it will be useful,
+// but WITHOUT ANY WARRANTY; without even the implied warranty of
+// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+// GNU Lesser General Public License for more details.
+//
+// You should have received a copy of the GNU Lesser General Public License
+// along with this RabbitExpress. If not, see <http://www.gnu.org/licenses/>.
+// </summary>
+// ***********************************************************************
+namespace RabbitExpress
+{
+    using System;
+
+    public class QueueConfig
+    {
+        public Uri ConnectionString { get; set; }
+        public ushort PrefetchSize { get; set; }
+    }
+}

RabbitExpress/RabbitExpress.csproj

@@ -22,6 +22,8 @@
 	</PropertyGroup>
 
 	<ItemGroup>
+		<PackageReference Include="Microsoft.Extensions.Configuration" Version="2.2.0" />
+		<PackageReference Include="Microsoft.Extensions.Options" Version="2.2.0" />
 		<PackageReference Include="RabbitMQ.Client" Version="5.1.0" />
 		<PackageReference Include="MsgPack.Cli" Version="1.0.1" />
 		<PackageReference Include="SexyProxy" Version="2.0.104" />