config, docs

Author: danielgerlag

src/providers/WorkflowCore.Providers.AWS/README.md

@@ -1,6 +1,7 @@
 # AWS providers for Workflow Core
 
 * Provides Queueing support  on [Workflow Core](../../README.md) using AWS Simple Queue Service.
+* Provides Distributed locking support  on [Workflow Core](../../README.md) using DynamoDB.
 
 This makes it possible to have a cluster of nodes processing your workflows.
 
@@ -14,8 +15,12 @@ PM> Install-Package WorkflowCore.Providers.AWS
 
 ## Usage
 
-Use the .UseAwsSimpleQueueService extension method when building your service provider.
+Use the `.UseAwsSimpleQueueService` and `.UseAwsDynamoLocking` extension methods when building your service provider.
 
 ```C#
-services.AddWorkflow(x => x.UseAwsSimpleQueueService(awsCredentials, amazonSQSConfig));
+services.AddWorkflow(cfg =>
+{
+    cfg.UseAwsSimpleQueueService(new EnvironmentVariablesAWSCredentials(), new AmazonSQSConfig() { RegionEndpoint = RegionEndpoint.USWest2 });
+    cfg.UseAwsDynamoLocking(new EnvironmentVariablesAWSCredentials(), new AmazonDynamoDBConfig() { RegionEndpoint = RegionEndpoint.USWest2 }, "workflow-core-locks");
+});
 ```

src/providers/WorkflowCore.Providers.AWS/Services/DynamoLockProvider.cs

@@ -196,7 +196,7 @@ private async Task CreateTable()
                 try
                 {
                     await Task.Delay(1000);
-                    var poll = await _client.DescribeTableAsync(_tableName, _cancellationTokenSource.Token);
+                    var poll = await _client.DescribeTableAsync(_tableName);
                     created = (poll.Table.TableStatus == TableStatus.ACTIVE);
                     i++;
                 }

src/providers/WorkflowCore.Providers.AWS/WorkflowCore.Providers.AWS.csproj

@@ -5,12 +5,14 @@
     <Authors>Daniel Gerlag</Authors>
     <Description>AWS providers for Workflow Core
 
-- Provides Queueing support  on Workflow Core</Description>
+- Provides Queueing support on Workflow Core
+- Provides distributed locking support on Workflow Core</Description>
     <PackageLicenseUrl>https://github.com/danielgerlag/workflow-core/blob/master/LICENSE.md</PackageLicenseUrl>
     <PackageProjectUrl>https://github.com/danielgerlag/workflow-core</PackageProjectUrl>
     <RepositoryUrl>https://github.com/danielgerlag/workflow-core.git</RepositoryUrl>
     <RepositoryType>git</RepositoryType>
-    <Version>1.6.0</Version>
+    <Version>1.6.9</Version>
+    <AssemblyVersion>1.6.9.0</AssemblyVersion>
   </PropertyGroup>
 
   <ItemGroup>

src/samples/WorkflowCore.Sample04/Program.cs

@@ -11,6 +11,8 @@
 using WorkflowCore.Interface;
 using WorkflowCore.Persistence.MongoDB.Services;
 using WorkflowCore.Services;
+using Amazon.DynamoDBv2;
+using Amazon.SQS;
 
 namespace WorkflowCore.Sample04
 {
@@ -41,7 +43,7 @@ private static IServiceProvider ConfigureServices()
             //setup dependency injection
             IServiceCollection services = new ServiceCollection();
             services.AddLogging();
-            services.AddWorkflow();            
+            services.AddWorkflow();
             //services.AddWorkflow(x => x.UseMongoDB(@"mongodb://localhost:27017", "workflow"));
             //services.AddWorkflow(x => x.UseSqlServer(@"Server=.;Database=WorkflowCore;Trusted_Connection=True;", true, true));
             //services.AddWorkflow(x => x.UsePostgreSQL(@"Server=127.0.0.1;Port=5432;Database=workflow;User Id=postgres;", true, true));
@@ -59,6 +61,12 @@ private static IServiceProvider ConfigureServices()
             //    x.UseSqlServerLocking(@"Server=.\SQLEXPRESS;Database=WorkflowCore;Trusted_Connection=True;");
             //});
 
+            //services.AddWorkflow(cfg =>
+            //{
+            //    cfg.UseAwsSimpleQueueService(new EnvironmentVariablesAWSCredentials(), new AmazonSQSConfig() { RegionEndpoint = RegionEndpoint.USWest2 });
+            //    cfg.UseAwsDynamoLocking(new EnvironmentVariablesAWSCredentials(), new AmazonDynamoDBConfig() { RegionEndpoint = RegionEndpoint.USWest2 }, "workflow-core-locks");
+            //});
+
             //services.AddWorkflow(x => x.UseRedlock(new System.Net.DnsEndPoint("127.0.0.1", 32768)));
 
             //services.AddWorkflow(x =>