Merge pull request #10 from NCodeGroup/transports

Adding AmazonSQS transport

Author: polewskm

Directory.Build.props

@@ -7,7 +7,7 @@
 
     <AllowedOutputExtensionsInPackageBuildOutputFolder>$(AllowedOutputExtensionsInPackageBuildOutputFolder);.pdb</AllowedOutputExtensionsInPackageBuildOutputFolder>
 
-    <AssemblyVersion>1.0.7</AssemblyVersion>
+    <AssemblyVersion>1.0.8</AssemblyVersion>
     <FileVersion>$(AssemblyVersion)</FileVersion>
     <Version>$(AssemblyVersion)</Version>
 

Example.ConsoleHost/Example.ConsoleHost.csproj

@@ -24,6 +24,7 @@
 
   <ItemGroup>
     <ProjectReference Include="..\MassTransit.Extensions.Hosting.ActiveMq\MassTransit.Extensions.Hosting.ActiveMq.csproj" />
+    <ProjectReference Include="..\MassTransit.Extensions.Hosting.AmazonSqs\MassTransit.Extensions.Hosting.AmazonSqs.csproj" />
     <ProjectReference Include="..\MassTransit.Extensions.Hosting.RabbitMq\MassTransit.Extensions.Hosting.RabbitMq.csproj" />
     <ProjectReference Include="..\MassTransit.Extensions.Hosting\MassTransit.Extensions.Hosting.csproj" />
   </ItemGroup>

Example.ConsoleHost/Program.cs

@@ -20,6 +20,7 @@
 using GreenPipes;
 using MassTransit.Extensions.Hosting;
 using MassTransit.Extensions.Hosting.ActiveMq;
+using MassTransit.Extensions.Hosting.AmazonSqs;
 using MassTransit.Extensions.Hosting.RabbitMq;
 using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.DependencyInjection;
@@ -118,6 +119,16 @@ private static void ConfigureServices(HostBuilderContext context, IServiceCollec
                     });
                 });
 
+                // AmazonSQS
+                busBuilder.UseAmazonSqs(configuration.GetSection("MassTransit:AmazonSqs"), hostBuilder =>
+                {
+                    hostBuilder.UseServiceScope();
+                    hostBuilder.AddReceiveEndpoint("example-queue-4", endpointBuilder =>
+                    {
+                        endpointBuilder.AddConsumer<ExampleConsumer>();
+                    });
+                });
+
             });
         }
 

Example.ConsoleHost/appsettings.json

@@ -16,6 +16,13 @@
       "UseSsl": true,
       "Username": "guest",
       "Password": "guest"
+    },
+
+    "AmazonSqs": {
+      "ConnectionName": "connection-name-4",
+      "RegionSystemName": "us-east-1",
+      "AccessKey": "access-key-example",
+      "SecretKey": "secret-key-example"
     }
 
   }

Example.TopshelfHost/Program.cs

@@ -100,7 +100,7 @@ private static void ConfigureServices(IConfiguration configuration, IServiceColl
                     });
                 });
 
-                // see `Example.ConsoleHost` for examples with other transports such as ActiveMq, etc.
+                // see `Example.ConsoleHost` for examples with other transports such as ActiveMq, AmazonSqs, etc.
             });
         }
 

MassTransit.Extensions.Hosting.ActiveMq/ActiveMqHostBuilder.cs

@@ -76,7 +76,7 @@ private ActiveMqHostBuilder(IServiceCollection services, string connectionName)
         /// </summary>
         /// <param name="services"><see cref="IServiceCollection"/></param>
         /// <param name="connectionName">The client-provided connection name.</param>
-        /// <param name="hostAddress">The URI host address of the RabbitMQ host (example: rabbitmq://host:port/vhost).</param>
+        /// <param name="hostAddress">The URI host address of the ActiveMQ host (example: activemq://host:port/).</param>
         public ActiveMqHostBuilder(IServiceCollection services, string connectionName, Uri hostAddress)
             : this(services, connectionName)
         {
@@ -108,9 +108,10 @@ public ActiveMqHostBuilder(IServiceCollection services, string connectionName, s
         /// Initializes a new instance of the <see cref="ActiveMqHostBuilder"/> class.
         /// </summary>
         /// <param name="services"><see cref="IServiceCollection"/></param>
+        /// <param name="connectionName">The client-provided connection name.</param>
         /// <param name="configuration">The <see cref="IConfiguration"/> being bound.</param>
-        public ActiveMqHostBuilder(IServiceCollection services, IConfiguration configuration)
-            : this(services, configuration["ConnectionName"])
+        public ActiveMqHostBuilder(IServiceCollection services, string connectionName, IConfiguration configuration)
+            : this(services, connectionName)
         {
             if (configuration == null)
                 throw new ArgumentNullException(nameof(configuration));

MassTransit.Extensions.Hosting.ActiveMq/ActiveMqOptions.cs

@@ -47,7 +47,7 @@ public class ActiveMqOptions
         public string ConnectionName { get; set; } = string.Empty;
 
         /// <summary>
-        /// Gets or sets the ActiveMQ address to connect to (rabbitmq://host:port/vhost).
+        /// Gets or sets the ActiveMQ address to connect to (activemq://host:port/).
         /// </summary>
         public Uri HostAddress
         {

MassTransit.Extensions.Hosting.ActiveMq/UseActiveMqExtensions.cs

@@ -94,7 +94,8 @@ public static void UseActiveMq(this IMassTransitBuilder builder, IConfiguration
             if (configuration == null)
                 throw new ArgumentNullException(nameof(configuration));
 
-            var hostBuilder = new ActiveMqHostBuilder(builder.Services, configuration);
+            var connectionName = configuration["ConnectionName"];
+            var hostBuilder = new ActiveMqHostBuilder(builder.Services, connectionName, configuration);
             hostConfigurator?.Invoke(hostBuilder);
         }
 

MassTransit.Extensions.Hosting.ActiveMq/project.props

@@ -3,7 +3,7 @@
   <PropertyGroup>
 
     <Description>MassTransit ActiveMQ configuration extensions using Microsoft.Extensions.Hosting.IHostedService and Microsoft.Extensions.DependencyInjection.</Description>
-    <PackageTags>ActiveMq;MassTransit;IHostedService;Bus;Hosting</PackageTags>
+    <PackageTags>ActiveMQ;MassTransit;IHostedService;Bus;Hosting</PackageTags>
 
   </PropertyGroup>
 </Project>