Merge pull request #4 from GodelTech/feature/add-interface

add interface

Author: rodchenkov

src/GodelTech.Messaging.AzureServiceBus/AzureServiceBusSender.cs

@@ -9,7 +9,7 @@ namespace GodelTech.Messaging.AzureServiceBus
     /// <summary>
     /// Azure Service Bus sender
     /// </summary>
-    public class AzureServiceBusSender
+    public class AzureServiceBusSender : IAzureServiceBusSender
     {
         private readonly ServiceBusClient _serviceBusClient;
         private readonly AzureServiceBusOptions _azureServiceBusOptions;

src/GodelTech.Messaging.AzureServiceBus/DependencyInjection/ServiceCollectionExtensions.cs

@@ -29,7 +29,7 @@ public static IServiceCollection AddAzureServiceBusSender(
             services.Configure(optionsAction);
 
             // AzureServiceBusSender
-            services.AddTransient<AzureServiceBusSender>();
+            services.AddTransient<IAzureServiceBusSender, AzureServiceBusSender>();
 
             return services;
         }

src/GodelTech.Messaging.AzureServiceBus/IAzureServiceBusSender.cs

@@ -0,0 +1,22 @@
+using System;
+using System.Threading.Tasks;
+
+namespace GodelTech.Messaging.AzureServiceBus
+{
+    /// <summary>
+    /// Interface of Azure Service Bus sender
+    /// </summary>
+    public interface IAzureServiceBusSender
+    {
+        /// <summary>
+        /// Asynchronously sends TModel object as JSON to Azure Service Bus queue.
+        /// Queue is select by key from options.
+        /// </summary>
+        /// <typeparam name="TModel">The type of the T model.</typeparam>
+        /// <param name="queueKey">Queue key.</param>
+        /// <param name="model">The model.</param>
+        /// <exception cref="ArgumentOutOfRangeException">No queue found with provided key.</exception>
+        public Task SendAsync<TModel>(string queueKey, TModel model)
+            where TModel : class;
+    }
+}

test/GodelTech.Messaging.AzureServiceBus.Tests/DependencyInjection/ServiceCollectionExtensionsTests.cs

@@ -43,8 +43,9 @@ public void AddAzureServiceBusSender_Success()
             Assert.NotNull(resultOptionsAction.Value);
             Assert.Equal(queues, resultOptionsAction.Value.Queues);
 
-            var resultAzureServiceBusSender = provider.GetRequiredService<AzureServiceBusSender>();
+            var resultAzureServiceBusSender = provider.GetRequiredService<IAzureServiceBusSender>();
             Assert.NotNull(resultAzureServiceBusSender);
+            Assert.IsType<AzureServiceBusSender>(resultAzureServiceBusSender);
         }
     }
 }