From f2adaaead51f3526c41792a0b27fc2b56a51ca25 Mon Sep 17 00:00:00 2001
From: Mark van Renswoude <mark@x2software.net>
Date: Wed, 19 Dec 2018 16:37:45 +0100
Subject: [PATCH 1/7] Removed X2Software prefix in preparation for v1.0

---
 Tapeti.Annotations/Tapeti.Annotations.nuspec         | 2 +-
 Tapeti.DataAnnotations/Tapeti.DataAnnotations.nuspec | 4 ++--
 Tapeti.Flow.SQL/Tapeti.Flow.SQL.nuspec               | 6 +++---
 Tapeti.Flow/Tapeti.Flow.nuspec                       | 6 +++---
 Tapeti.Serilog/Tapeti.Serilog.nuspec                 | 4 ++--
 Tapeti.SimpleInjector/Tapeti.SimpleInjector.nuspec   | 4 ++--
 Tapeti/Tapeti.nuspec                                 | 4 ++--
 7 files changed, 15 insertions(+), 15 deletions(-)

diff --git a/Tapeti.Annotations/Tapeti.Annotations.nuspec b/Tapeti.Annotations/Tapeti.Annotations.nuspec
index f804dca..68e8268 100644
--- a/Tapeti.Annotations/Tapeti.Annotations.nuspec
+++ b/Tapeti.Annotations/Tapeti.Annotations.nuspec
@@ -1,7 +1,7 @@
 <?xml version="1.0"?>
 <package >
   <metadata>
-    <id>X2Software.Tapeti.Annotations</id>
+    <id>Tapeti.Annotations</id>
     <version>$version$</version>
     <title>Tapeti Annotations</title>
     <authors>Mark van Renswoude</authors>
diff --git a/Tapeti.DataAnnotations/Tapeti.DataAnnotations.nuspec b/Tapeti.DataAnnotations/Tapeti.DataAnnotations.nuspec
index edd32a8..ddf90b8 100644
--- a/Tapeti.DataAnnotations/Tapeti.DataAnnotations.nuspec
+++ b/Tapeti.DataAnnotations/Tapeti.DataAnnotations.nuspec
@@ -1,7 +1,7 @@
 <?xml version="1.0"?>
 <package >
   <metadata>
-    <id>X2Software.Tapeti.DataAnnotations</id>
+    <id>Tapeti.DataAnnotations</id>
     <version>$version$</version>
     <title>Tapeti DataAnnotations</title>
     <authors>Mark van Renswoude</authors>
@@ -14,7 +14,7 @@
     <copyright></copyright>
     <tags>rabbitmq tapeti dataannotations</tags>
     <dependencies>
-      <dependency id="X2Software.Tapeti" version="[$version$]" />
+      <dependency id="Tapeti" version="[$version$]" />
       <dependency id="System.ComponentModel.Annotations" version="4.5.0" />
     </dependencies>
   </metadata>
diff --git a/Tapeti.Flow.SQL/Tapeti.Flow.SQL.nuspec b/Tapeti.Flow.SQL/Tapeti.Flow.SQL.nuspec
index adc8569..81a6fe0 100644
--- a/Tapeti.Flow.SQL/Tapeti.Flow.SQL.nuspec
+++ b/Tapeti.Flow.SQL/Tapeti.Flow.SQL.nuspec
@@ -1,7 +1,7 @@
 <?xml version="1.0"?>
 <package >
   <metadata>
-    <id>X2Software.Tapeti.Flow.SQL</id>
+    <id>Tapeti.Flow.SQL</id>
     <version>$version$</version>
     <title>Tapeti Flow SQL</title>
     <authors>Mark van Renswoude</authors>
@@ -14,8 +14,8 @@
     <copyright></copyright>
     <tags>rabbitmq tapeti sql</tags>
     <dependencies>
-      <dependency id="X2Software.Tapeti" version="[$version$]" />
-      <dependency id="X2Software.Tapeti.Flow" version="[$version$]" />
+      <dependency id="Tapeti" version="[$version$]" />
+      <dependency id="Tapeti.Flow" version="[$version$]" />
       <dependency id="System.Data.SqlClient" version="4.5.0" />
     </dependencies>
   </metadata>
diff --git a/Tapeti.Flow/Tapeti.Flow.nuspec b/Tapeti.Flow/Tapeti.Flow.nuspec
index ad1e5a9..27e8251 100644
--- a/Tapeti.Flow/Tapeti.Flow.nuspec
+++ b/Tapeti.Flow/Tapeti.Flow.nuspec
@@ -1,7 +1,7 @@
 <?xml version="1.0"?>
 <package >
   <metadata>
-    <id>X2Software.Tapeti.Flow</id>
+    <id>Tapeti.Flow</id>
     <version>$version$</version>
     <title>Tapeti Flow</title>
     <authors>Menno van Lavieren, Mark van Renswoude</authors>
@@ -14,8 +14,8 @@
     <copyright></copyright>
     <tags>rabbitmq tapeti flow</tags>
     <dependencies>
-      <dependency id="X2Software.Tapeti" version="[$version$]" />
-      <dependency id="X2Software.Tapeti.Annotations" version="[$version$]" />
+      <dependency id="Tapeti" version="[$version$]" />
+      <dependency id="Tapeti.Annotations" version="[$version$]" />
     </dependencies>
   </metadata>
   <files>
diff --git a/Tapeti.Serilog/Tapeti.Serilog.nuspec b/Tapeti.Serilog/Tapeti.Serilog.nuspec
index 6e7bdcd..80c6cba 100644
--- a/Tapeti.Serilog/Tapeti.Serilog.nuspec
+++ b/Tapeti.Serilog/Tapeti.Serilog.nuspec
@@ -1,7 +1,7 @@
 <?xml version="1.0"?>
 <package >
   <metadata>
-    <id>X2Software.Tapeti.Serilog</id>
+    <id>Tapeti.Serilog</id>
     <version>$version$</version>
     <title>Tapeti Serilog</title>
     <authors>Hans Mulder</authors>
@@ -14,7 +14,7 @@
     <copyright></copyright>
     <tags>rabbitmq tapeti simpleinjector serilog</tags>
     <dependencies>
-      <dependency id="X2Software.Tapeti" version="[$version$]" />
+      <dependency id="Tapeti" version="[$version$]" />
       <dependency id="Serilog" version="2.7.1" />
     </dependencies>
   </metadata>
diff --git a/Tapeti.SimpleInjector/Tapeti.SimpleInjector.nuspec b/Tapeti.SimpleInjector/Tapeti.SimpleInjector.nuspec
index c1ed9a3..8bfbe3d 100644
--- a/Tapeti.SimpleInjector/Tapeti.SimpleInjector.nuspec
+++ b/Tapeti.SimpleInjector/Tapeti.SimpleInjector.nuspec
@@ -1,7 +1,7 @@
 <?xml version="1.0"?>
 <package >
   <metadata>
-    <id>X2Software.Tapeti.SimpleInjector</id>
+    <id>Tapeti.SimpleInjector</id>
     <version>$version$</version>
     <title>Tapeti SimpleInjector</title>
     <authors>Mark van Renswoude</authors>
@@ -14,7 +14,7 @@
     <copyright></copyright>
     <tags>rabbitmq tapeti simpleinjector</tags>
     <dependencies>
-      <dependency id="X2Software.Tapeti" version="[$version$]" />
+      <dependency id="Tapeti" version="[$version$]" />
       <dependency id="SimpleInjector" version="4.3.0" />
     </dependencies>
   </metadata>
diff --git a/Tapeti/Tapeti.nuspec b/Tapeti/Tapeti.nuspec
index cc0d1c9..72e9360 100644
--- a/Tapeti/Tapeti.nuspec
+++ b/Tapeti/Tapeti.nuspec
@@ -1,7 +1,7 @@
 <?xml version="1.0"?>
 <package >
   <metadata>
-    <id>X2Software.Tapeti</id>
+    <id>Tapeti</id>
     <version>$version$</version>
     <title>Tapeti</title>
     <authors>Mark van Renswoude</authors>
@@ -14,7 +14,7 @@
     <copyright></copyright>
     <tags>rabbitmq tapeti</tags>
     <dependencies>
-      <dependency id="X2Software.Tapeti.Annotations" version="[$version$]" />
+      <dependency id="Tapeti.Annotations" version="[$version$]" />
       <dependency id="Newtonsoft.Json" version="11.0.2"/>
       <dependency id="RabbitMQ.Client" version="5.0.1"/>
       <dependency id="System.Configuration.ConfigurationManager" version="4.5.0"/>

From 326574433059cc6ff1151f10eb6cac8078858e2b Mon Sep 17 00:00:00 2001
From: Mark van Renswoude <mark@x2software.net>
Date: Wed, 19 Dec 2018 18:07:48 +0100
Subject: [PATCH 2/7] Fixed reference to renamed NuGet packages

---
 appveyor.yml | 12 ++++++------
 1 file changed, 6 insertions(+), 6 deletions(-)

diff --git a/appveyor.yml b/appveyor.yml
index 9fbce10..91f2568 100644
--- a/appveyor.yml
+++ b/appveyor.yml
@@ -11,17 +11,17 @@ before_build:
 after_build:
   - cmd: ECHO nuget pack Tapeti\Tapeti.nuspec -version "%GitVersion_NuGetVersion%" -prop "target=%CONFIGURATION%"
   - cmd: nuget pack Tapeti\Tapeti.nuspec -version "%GitVersion_NuGetVersion%" -prop "target=%CONFIGURATION%"
-  - cmd: appveyor PushArtifact "X2Software.Tapeti.%GitVersion_NuGetVersion%.nupkg"
+  - cmd: appveyor PushArtifact "Tapeti.%GitVersion_NuGetVersion%.nupkg"
   - cmd: nuget pack Tapeti.Annotations\Tapeti.Annotations.nuspec -version "%GitVersion_NuGetVersion%" -prop "target=%CONFIGURATION%"
-  - cmd: appveyor PushArtifact "X2Software.Tapeti.Annotations.%GitVersion_NuGetVersion%.nupkg"
+  - cmd: appveyor PushArtifact "Tapeti.Annotations.%GitVersion_NuGetVersion%.nupkg"
   - cmd: nuget pack Tapeti.DataAnnotations\Tapeti.DataAnnotations.nuspec -version "%GitVersion_NuGetVersion%" -prop "target=%CONFIGURATION%"
-  - cmd: appveyor PushArtifact "X2Software.Tapeti.DataAnnotations.%GitVersion_NuGetVersion%.nupkg"
+  - cmd: appveyor PushArtifact "Tapeti.DataAnnotations.%GitVersion_NuGetVersion%.nupkg"
   - cmd: nuget pack Tapeti.Flow\Tapeti.Flow.nuspec -version "%GitVersion_NuGetVersion%" -prop "target=%CONFIGURATION%"
-  - cmd: appveyor PushArtifact "X2Software.Tapeti.Flow.%GitVersion_NuGetVersion%.nupkg"
+  - cmd: appveyor PushArtifact "Tapeti.Flow.%GitVersion_NuGetVersion%.nupkg"
   - cmd: nuget pack Tapeti.SimpleInjector\Tapeti.SimpleInjector.nuspec -version "%GitVersion_NuGetVersion%" -prop "target=%CONFIGURATION%"
-  - cmd: appveyor PushArtifact "X2Software.Tapeti.SimpleInjector.%GitVersion_NuGetVersion%.nupkg"
+  - cmd: appveyor PushArtifact "Tapeti.SimpleInjector.%GitVersion_NuGetVersion%.nupkg"
   - cmd: nuget pack Tapeti.Serilog\Tapeti.Serilog.nuspec -version "%GitVersion_NuGetVersion%" -prop "target=%CONFIGURATION%"
-  - cmd: appveyor PushArtifact "X2Software.Tapeti.Serilog.%GitVersion_NuGetVersion%.nupkg"
+  - cmd: appveyor PushArtifact "Tapeti.Serilog.%GitVersion_NuGetVersion%.nupkg"
 
 assembly_info:
   patch: false

From 2042cc074f3d6600fb16d3c710d27814477ef7ef Mon Sep 17 00:00:00 2001
From: Mark van Renswoude <mark@x2software.net>
Date: Wed, 19 Dec 2018 21:40:53 +0100
Subject: [PATCH 3/7] Fixed incorrect assertion caused by fixing "code issues"
 (oh the irony)

---
 Tapeti.Flow/Default/FlowProvider.cs | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/Tapeti.Flow/Default/FlowProvider.cs b/Tapeti.Flow/Default/FlowProvider.cs
index 7115ae9..5a6a49a 100644
--- a/Tapeti.Flow/Default/FlowProvider.cs
+++ b/Tapeti.Flow/Default/FlowProvider.cs
@@ -56,11 +56,10 @@ namespace Tapeti.Flow.Default
         private async Task SendRequest(FlowContext context, object message, ResponseHandlerInfo responseHandlerInfo, 
             string convergeMethodName = null, bool convergeMethodTaskSync = false)
         {
-            Debug.Assert(context.FlowState != null, "context.FlowState != null");
-
             if (context.FlowState == null)
             {
                 await CreateNewFlowState(context);
+                Debug.Assert(context.FlowState != null, "context.FlowState != null");
             }
 
             var continuationID = Guid.NewGuid();

From 525e83bde99b4704cb366f92fde7768073a9f554 Mon Sep 17 00:00:00 2001
From: Mark van Renswoude <mark@x2software.net>
Date: Wed, 19 Dec 2018 21:41:19 +0100
Subject: [PATCH 4/7] Implemented SQL flow repository

---
 Tapeti.Flow.SQL/ConfigExtensions.cs           | 14 ++--
 .../SqlConnectionFlowRepository.cs            | 69 ++++++++++++-------
 Test/Program.cs                               |  5 +-
 3 files changed, 53 insertions(+), 35 deletions(-)

diff --git a/Tapeti.Flow.SQL/ConfigExtensions.cs b/Tapeti.Flow.SQL/ConfigExtensions.cs
index 9dd039b..2e2e247 100644
--- a/Tapeti.Flow.SQL/ConfigExtensions.cs
+++ b/Tapeti.Flow.SQL/ConfigExtensions.cs
@@ -7,9 +7,9 @@ namespace Tapeti.Flow.SQL
 {
     public static class ConfigExtensions
     {
-        public static TapetiConfig WithFlowSqlRepository(this TapetiConfig config, string connectionString, int serviceId, string schema = "dbo")
+        public static TapetiConfig WithFlowSqlRepository(this TapetiConfig config, string connectionString, string tableName = "Flow")
         {
-            config.Use(new FlowSqlRepositoryBundle(connectionString, serviceId, schema));
+            config.Use(new FlowSqlRepositoryBundle(connectionString, tableName));
             return config;
         }
     }
@@ -18,21 +18,19 @@ namespace Tapeti.Flow.SQL
     internal class FlowSqlRepositoryBundle : ITapetiExtension
     {
         private readonly string connectionString;
-        private readonly string schema;
-        private readonly int serviceId;
+        private readonly string tableName;
 
 
-        public FlowSqlRepositoryBundle(string connectionString, int serviceId, string schema)
+        public FlowSqlRepositoryBundle(string connectionString, string tableName)
         {
             this.connectionString = connectionString;
-            this.serviceId = serviceId;
-            this.schema = schema;
+            this.tableName = tableName;
         }
 
 
         public void RegisterDefaults(IDependencyContainer container)
         {
-            container.RegisterDefault<IFlowRepository>(() => new SqlConnectionFlowRepository(connectionString, serviceId, schema));
+            container.RegisterDefaultSingleton<IFlowRepository>(() => new SqlConnectionFlowRepository(connectionString, tableName));
         }
 
 
diff --git a/Tapeti.Flow.SQL/SqlConnectionFlowRepository.cs b/Tapeti.Flow.SQL/SqlConnectionFlowRepository.cs
index 4a8640c..d32b645 100644
--- a/Tapeti.Flow.SQL/SqlConnectionFlowRepository.cs
+++ b/Tapeti.Flow.SQL/SqlConnectionFlowRepository.cs
@@ -8,32 +8,28 @@ using Newtonsoft.Json;
 namespace Tapeti.Flow.SQL
 {
     /*
-        Assumes the following table layout (schema configurable):
+        Assumes the following table layout (table name configurable and may include schema):
          
      
-        create table shared.Flow
+        create table Flow
         (
 	        FlowID uniqueidentifier not null,
-	        ServiceID int not null,
 	        CreationTime datetime2(3) not null,
 	        StateJson nvarchar(max) null,
 
 	        constraint PK_Flow primary key clustered (FlowID)
         );
-        go;
     */
     public class SqlConnectionFlowRepository : IFlowRepository
     {
         private readonly string connectionString;
-        private readonly int serviceId;
-        private readonly string schema;
+        private readonly string tableName;
 
 
-        public SqlConnectionFlowRepository(string connectionString, int serviceId, string schema)
+        public SqlConnectionFlowRepository(string connectionString, string tableName = "Flow")
         {
             this.connectionString = connectionString;
-            this.serviceId = serviceId;
-            this.schema = schema;
+            this.tableName = tableName;
         }
 
 
@@ -41,14 +37,7 @@ namespace Tapeti.Flow.SQL
         {
             using (var connection = await GetConnection())
             {
-                var flowQuery = new SqlCommand($"select FlowID, StateJson from {schema}.Flow " +
-                                                "where ServiceID = @ServiceID ",
-                                                connection);
-                var flowServiceParam = flowQuery.Parameters.Add("@ServiceID", SqlDbType.Int);
-
-                flowServiceParam.Value = serviceId;
-
-
+                var flowQuery = new SqlCommand($"select FlowID, StateJson from {tableName}", connection);
                 var flowReader = await flowQuery.ExecuteReaderAsync();
 
                 var result = new List<KeyValuePair<Guid, T>>();
@@ -67,21 +56,53 @@ namespace Tapeti.Flow.SQL
 
         }
 
-        public Task CreateState<T>(Guid flowID, T state, DateTime timestamp)
+        public async Task CreateState<T>(Guid flowID, T state, DateTime timestamp)
         {
-            //var stateJson = JsonConvert.SerializeObject(state);
+            using (var connection = await GetConnection())
+            {
+                var query = new SqlCommand($"insert into {tableName} (FlowID, StateJson, CreationTime)" +
+                                            "values (@FlowID, @StateJson, @CreationTime)",
+                                            connection);
 
-            throw new NotImplementedException();
+                var flowIDParam = query.Parameters.Add("@FlowID", SqlDbType.UniqueIdentifier);
+                var stateJsonParam = query.Parameters.Add("@StateJson", SqlDbType.NVarChar);
+                var creationTimeParam = query.Parameters.Add("@CreationTime", SqlDbType.DateTime2);
+
+                flowIDParam.Value = flowID;
+                stateJsonParam.Value = JsonConvert.SerializeObject(state);
+                creationTimeParam.Value = timestamp;
+
+                await query.ExecuteNonQueryAsync();
+            }
         }
 
-        public Task UpdateState<T>(Guid flowID, T state)
+        public async Task UpdateState<T>(Guid flowID, T state)
         {
-            throw new NotImplementedException();
+            using (var connection = await GetConnection())
+            {
+                var query = new SqlCommand($"update {tableName} set StateJson = @StateJson where FlowID = @FlowID", connection);
+
+                var flowIDParam = query.Parameters.Add("@FlowID", SqlDbType.UniqueIdentifier);
+                var stateJsonParam = query.Parameters.Add("@StateJson", SqlDbType.NVarChar);
+
+                flowIDParam.Value = flowID;
+                stateJsonParam.Value = JsonConvert.SerializeObject(state);
+
+                await query.ExecuteNonQueryAsync();
+            }
         }
 
-        public Task DeleteState(Guid flowID)
+        public async Task DeleteState(Guid flowID)
         {
-            throw new NotImplementedException();
+            using (var connection = await GetConnection())
+            {
+                var query = new SqlCommand($"delete from {tableName} where FlowID = @FlowID", connection);
+
+                var flowIDParam = query.Parameters.Add("@FlowID", SqlDbType.UniqueIdentifier);
+                flowIDParam.Value = flowID;
+
+                await query.ExecuteNonQueryAsync();
+            }
         }
 
 
diff --git a/Test/Program.cs b/Test/Program.cs
index caad2c9..be6eed9 100644
--- a/Test/Program.cs
+++ b/Test/Program.cs
@@ -5,6 +5,7 @@ using Tapeti.DataAnnotations;
 using Tapeti.Flow;
 using Tapeti.SimpleInjector;
 using System.Threading;
+using Tapeti.Flow.SQL;
 
 namespace Test
 {
@@ -12,10 +13,7 @@ namespace Test
     {
         private static void Main()
         {
-            // TODO SQL based flow store
             // TODO logging
-            // TODO uitzoeken of we consumers kunnen pauzeren (denk: SQL down) --> nee, EFDBContext Get Async maken en retryen? kan dat, of timeout dan Rabbit?
-
 
             var container = new Container();
             container.Register<MarcoEmitter>();
@@ -23,6 +21,7 @@ namespace Test
             container.Register<ILogger, Tapeti.Default.ConsoleLogger>();
 
             var config = new TapetiConfig(new SimpleInjectorDependencyResolver(container))
+                //.WithFlowSqlRepository("Server=localhost;Database=TapetiTest;Integrated Security=true")
                 .WithFlow()
                 .WithDataAnnotations()
                 .RegisterAllControllers()

From 9708c9880e8062b44c3050f57c9c2cb0d3f435ac Mon Sep 17 00:00:00 2001
From: Mark van Renswoude <mark@x2software.net>
Date: Wed, 19 Dec 2018 21:58:50 +0100
Subject: [PATCH 5/7] Added Tapeti.Flow.SQL to AppVeyor build

---
 Tapeti.Serilog/Tapeti.Serilog.nuspec |   4 ++--
 appveyor.yml                         |   2 ++
 resources/icons/Tapeti.Flow.SQL.png  | Bin 0 -> 6156 bytes
 resources/icons/Tapeti.Serilog.png   | Bin 0 -> 6071 bytes
 4 files changed, 4 insertions(+), 2 deletions(-)
 create mode 100644 resources/icons/Tapeti.Flow.SQL.png
 create mode 100644 resources/icons/Tapeti.Serilog.png

diff --git a/Tapeti.Serilog/Tapeti.Serilog.nuspec b/Tapeti.Serilog/Tapeti.Serilog.nuspec
index 80c6cba..26fd39c 100644
--- a/Tapeti.Serilog/Tapeti.Serilog.nuspec
+++ b/Tapeti.Serilog/Tapeti.Serilog.nuspec
@@ -8,11 +8,11 @@
     <owners>Hans Mulder</owners>
     <licenseUrl>https://raw.githubusercontent.com/MvRens/Tapeti/master/UNLICENSE</licenseUrl>
     <projectUrl>https://github.com/MvRens/Tapeti</projectUrl>
-    <iconUrl>https://raw.githubusercontent.com/MvRens/Tapeti/master/resources/icons/Tapeti.SimpleInjector.png</iconUrl>
+    <iconUrl>https://raw.githubusercontent.com/MvRens/Tapeti/master/resources/icons/Tapeti.Serilog.png</iconUrl>
     <requireLicenseAcceptance>false</requireLicenseAcceptance>
     <description>Serilog integration package for Tapeti</description>
     <copyright></copyright>
-    <tags>rabbitmq tapeti simpleinjector serilog</tags>
+    <tags>rabbitmq tapeti serilog</tags>
     <dependencies>
       <dependency id="Tapeti" version="[$version$]" />
       <dependency id="Serilog" version="2.7.1" />
diff --git a/appveyor.yml b/appveyor.yml
index 91f2568..bbf7f81 100644
--- a/appveyor.yml
+++ b/appveyor.yml
@@ -18,6 +18,8 @@ after_build:
   - cmd: appveyor PushArtifact "Tapeti.DataAnnotations.%GitVersion_NuGetVersion%.nupkg"
   - cmd: nuget pack Tapeti.Flow\Tapeti.Flow.nuspec -version "%GitVersion_NuGetVersion%" -prop "target=%CONFIGURATION%"
   - cmd: appveyor PushArtifact "Tapeti.Flow.%GitVersion_NuGetVersion%.nupkg"
+  - cmd: nuget pack Tapeti.Flow\SQL.Tapeti.Flow.SQL.nuspec -version "%GitVersion_NuGetVersion%" -prop "target=%CONFIGURATION%"
+  - cmd: appveyor PushArtifact "Tapeti.Flow.SQL.%GitVersion_NuGetVersion%.nupkg"
   - cmd: nuget pack Tapeti.SimpleInjector\Tapeti.SimpleInjector.nuspec -version "%GitVersion_NuGetVersion%" -prop "target=%CONFIGURATION%"
   - cmd: appveyor PushArtifact "Tapeti.SimpleInjector.%GitVersion_NuGetVersion%.nupkg"
   - cmd: nuget pack Tapeti.Serilog\Tapeti.Serilog.nuspec -version "%GitVersion_NuGetVersion%" -prop "target=%CONFIGURATION%"
diff --git a/resources/icons/Tapeti.Flow.SQL.png b/resources/icons/Tapeti.Flow.SQL.png
new file mode 100644
index 0000000000000000000000000000000000000000..eacf05f946df5fef952ee391574539cceaca47b2
GIT binary patch
literal 6156
zcmV+n81v_eP)<h;3K|Lk000e1NJLTq002M$002M;1^@s6s%dfF0000PbVXQnQ*UN;
zcVTj606}DLVr3vnZDD6+Qe|Oed2z{QJOBU}u1Q2eRCwC#dI_{$WqJ0q=QGdKo$n<H
zBqRY6EOBTRqpPA-1}C(v)gP*@Re!7KuN6cQ720AK5U~!et?)}7khUOZsa<NA1OsRo
zGLV~_+$ndyXFg}2z4zHepM5xV#h92uux2g3tZ&_ubN2K-@B2Q_^X|QY7srd^#qr|!
zJsa15aC6~{pS&dTyEvEh`?mNmU;8#;X})~x{(T4Ee)%PvAN}FOyDG=K?>jG8r}o8^
zKX}V4&fWCK8$z@9J-uWeYaj9V4FJ(~1O-w-^Mp$lXJ)_u)lXfv@_6<;Z{_f5m3iZ_
z!JeK+MA5mc*|HzM`N|8zryKyDYk8TZ)|LfZ2uSkU(tPEPfBg8LzU21Lz5A&9{N<Zp
z7G9C>xoa@df7W282Ob<qa%koL(F2#CasU|ZHk5#(=kjs1+f7(4YtzEa(vOxG%Nvij
zPkp)h=KffG!&!wi`V&c1st!R2!qnRz`NZ2cgik2|8ZFBU#}kjOUbn`z;lgs-h=!x7
z>4~YY-T2-=={bD+PyfZmQalj($Y3Od(+fcq!a=lJ60Ej_NHj4rad7FirxXC!+`0|p
z2d2Jan(ZGAuUz5Imuje)22$z#hViMHUtaf~*ZvA86c=lo2Kxuj8q6jjs1g!w7a<L3
zISS?)f<L`e3IKmx`_DgXj!z%_z|ctFR4yODOi_m`M+ic1VSHlYz5j6KTRYo*>$C3{
zRtyZhH4~2uiC7ehBzC6Vwo$3np*JmWq`xqJ$^p>Hgs(ife`$IC0|R~OHarW>W(Cn`
z6q2C*#rXJqufI*HR7%H!fmbBMA;^*d&$iIE3<!b?Rg+;^Mm3+!9ylcd@W)cIv^5;i
zzFUa%LhT~ceHx)~EV{I?_(A{oL?W?{zpn|(3OvVwB1>=_8{wdax?Y0q7*D@;^B*;T
z(>a7=U4*P@=kU+@{`ojxb%afx;Jn{9&AVR+5N^Htg406+9)ITPiKy9DVM`&RArz+%
z?pyWh^DlgrQ#HT6uD4gqNDZ{=Ma<eV9v>USzH$wvivG6`?w-2(gfoDPKA-dJoMry^
zKMz^>7S8Jqn^n%6x$QXT<<B<&mTit^^Z7f%@c<;L4cDqeaNFs8B6*b>49@M?wWp=G
z{gjvBGW7+CpB1;032ob%Jz*cvUBuTpCpkATvLl?AaDLj4GUt7VP5=85ZhHmi2Tv9V
z?vv<(e)FN<f8@q(kTh*;CKvZYOa;+v!E2KgE$`1FF|}$4&g^`#1kba15E?1bg1=p(
zsnbVT%@YQIi@B}4Xn$c7$Gd<o7#q4-acvif4{;73W8uS`pXNuOt%ti=_A6um^yEW<
zh+38;8<7AP=`<iYZvMZve!qXIQT=XJufuUI%Af$ls-aO|CLoTd2GnPM=T7iB0QvFC
zZt3_y?BM)Qf1!uWZ9Yi+eFx_dr=Ml7J`(7L<<#=Y{JvbAY)_BpIU=MW#lh46(6PNc
z_DzmkY9tAjC7_oVVLAc=TENUEl+oV`0G|N6QT%%Mg1sY5e{nY-9_enm_=^&{VBB-q
z;kR@bo#ed2&!D4S$H#8`u@{TPwnyVpm^Ph0r(x13+Rn<i{>gd!8;#P#woFiD8>x60
z4ZTeTsn5Oay!GW{mfn$Sk$*nK`G301@3Z@poVRx`xN<mQcDMC`@VCA0@F@PK#U1JV
zho8eAV-w>KH}uwDtC|A0Y7+p5M%h(c^(Da++-JsSC(n<!OL%hUBwD8A>)XUtTkdsF
zCIimzrsNfeMCX=njaQCR`#u4VbiW$!X3X#jlAxb$emUHHq~CSZ*dB_<^hi7oK^8jt
z9Sj7_k^TX<1spI12e#Y9$RL|2tIZw)KR>Sa`v?oV`&cP?l-jQx1&E8gS#>l5yxcD@
z{@0)PbdT|CBbrQ3K??jhnWyKc9A@$n1S4`K#qQ67Jmo4fdIvN7E<hCs`KD;=NdfRY
zkl@52K=`HOyS8#y6}BBRy)FS>)Ge=$@*M5BmtXxKZrhQ*FgVih^bKTDYKUmqv6p`5
z2R|Pi&i2c}fQc&U=I(7XkfV|2=1n6zk1O+zB~koyG3VJ`i8`mt3x_*FKU=mOTKnD4
zw{+)o$2znut~e2y^+!O_9+4pz3%%jo*i?n)C-{;L8&3b&!qncgXU7dpnoX#g2xgaB
z)>&tsVE~Wf`5-}marbwlG;#Pv`zhXyq95Vgjzofo05Wm1B<PQz7SI(*+t-&4=gwW5
zp+QQby0GuBJhv{5O-M-R6s%ko!{{i&3rqDRcbPw#61cdl-&b}?@RCDFaN=m3@j{be
z=ceb!@4&*s{FA9r5}9xiYlbrz&ZeY@mPTPXkCp{UwuX?RtB*Xk>n$gBSJ-u&Cpd5C
zeC9+J!0juX_lUB5dsj(r<L6;cfpea}8ApmXe|rb#wf@Z=Kg$T_mA~mcZ+yi-f3COi
zCRq!kP{<%4I}lwHiXuQ$RfO3Z`%>w-?koFJ>h^te_3{6061?^(B<P!za<|m(KNbl-
zH&i(|XXyrvwu%3Ga4!xls)*$Vp)!=|sES-VgJ#`AI;KW4$=J7Ex+>pu(j@rX0&y4#
z9!{VWCrX0P-Zqx%?M5AK&&4?}zX)IX@;7kto6f_EwR!CN<$bUnAWI??BnhPh^EpWp
zPUl{8zjFYN0LT;1$8qN7mxhv&euzR7UUeR!<pZcp4PoH?x8vZ{F31F?VX#k7BWSct
zPnMzouVldUIsW}dR*4{<MdR=uN%Af$*2>5xBT$`btlKz<L^_2Q8L)57M$GNsLq00Q
zZ5v1@<B&vXrz`;Xe&OB8cs%k(&(<$#wc2lxl(4p3YJz`!bBut{z-wO72QMNa8j>L8
z*I;R494k-DU~;O2R7Ao2tl^w;0NnP;cLdYv_$MME_0K)m=!r#Xe>|V~TJS^>fp8D<
zF<^0YCtG3*6?X}ynnJ2~HTnjIurxl8h$_=K*+Mj|4DgVToH92>@BF(z6*AfA-;9j(
zUad%OPb8p1QxxP<F({Ia-hmuj-DNzpXB3gBhPq|I^&GU#8ht<+Ekj3Xp@B-(M7?3M
zeb6?)AQ|w*55GaE=z5ZxJJ^#i{NeoU{HAOsk!`zey`|f8hT+VUkM<McZ6E#859W^N
zm|Jgtx4;O0#Dn#Ta(P}bT6Jhr1d`(Seh!lH5b92w_1;1}lSVu2Ky5YP83LOhfxygR
zuzxj{4=!Wh^yBOZqcA-Cq7PiU>9e<fXZy@=1;FP&exa1i4PV+{7<prTdCFcqxc4+o
z6xNLl_C`vTn$+9ZOVq1~$5hyMyOUh3TmLa-{gw}3^nKg3J|Cjfd*4k*zIpuZ8!naR
z7H9rne}CWSQkksWYStl3QfJ|{Y7>P_j2?hA*sS4oufG7h$M&NwTgb1-Vsy_Q6c^_a
zj%MIydobfD_}SAW%1jUq*U3ax(|@iwb6igFNaG(qb7^X5?WV7tcIKu}W%4W5C*#4h
zmlq}m%|<PtsSssRfyoBk*I+}h`S)`DdvY)h6AQ~#t=?#@4+q0n2!eX{+u!i=sS94V
zdT#4OJ3Ei8{{MCFkY2tv^BTR`yeW~0{#9=e7thECl_0_a4W83NBATGv(_z+&uo^Yk
zN(gJ#Z)Ai6*vER`Kf4Tppr;iHD%)cudf=F0?0R|+0ulMnH7kd1yzlW*_oSW+eDkw^
z{IaH}eIwBK2P^tc+kj*wjoSQ96sLAT^*kQHq3!fAF*ya%Q;^B!QL0SC;Nmms0gO)0
zbuvNIf^eA?GxIafOV8c#L^2$Bs9atYre_YEfA;!y>td0Jn9Wem2%zV2UoN6roJZR#
zV$I4msFx2?(ri@g2259k6dOjg|6GWXI7avGK_TqnsfT}pwdcMXduI(i`p7RZJ-T~z
z;EdkQTkg1j=7b-N{Ks{hBl)EE*V#<&qjRNZV#bU?>sf<*ekGP?b|Zue;^8<ftA)AA
z{j{G=F4TczyXfsnqF5<nscgZr8E8f3;w7eXi$Ev{Ycj2BfO_4;P=6NDM1qk@5gq}S
zULm1Xk%`8!v@nN!E{1`gUKsU7)auMGHmjCV!(yp{xr&Hb{xszJR&l>7s*962IK7DZ
zqJg=kg)zO{c-=Q18a;5rB>3GMUVr9rPwLyM&{`K1ZNaTALngzj@gU5y1kJzs7)#P@
zNU+@&8dVw(hYJ-Yyz-Ts@ZkO1FuSmfU@V1bP{eYz(gA=y3+%Rzl`B?b_TYZ>a&hsH
zNZyD-V7dnc2Sozu`8IZG3b|w$ir^C1Dm=6iiN#QBc`zIap`e6Vy^5vL$MDql2mCxF
zd@gyYLC++&lkwPlzk2U)Ui=XO`0kBwlKRuJuf;X27v(Th*+wKBfyITU!vfk)4dD=p
z&N2~UIS4|V4M+mJcaLHC^fNF%Ifms*1BIS`EH9N2k|oHFg;+cZC*+_fn}bU*H=cbu
zj~ir<5Fm-r#I(ugtrBFj3^7FDQV9aq=sfX}1P=~5!4o7zB$c)AL1&2xfhbm-k;TH#
z9)(_SV7X?(<ZqUXAD?;7$WKn{j?i$v=i+!6o2tcW1Ol|1N))kl6ifA~PQ}<{I+-n~
zBzgqFc=qDj7J^LcnW=+luv61QVYEp~nS=_Hix|wt7#|n$ToTDt5}`m4sZ<&|<;;Jq
zr3u_$Fj?<9V&MQ3y1IZUzzf6(P>AOXLXuUqT>-=!l0-n$JqV_x&N<`BBn*q$<ysvg
zb{zclnp=P9o$x)udp>_@gsJm)jao@eQBGtv2sIEOst%&rJZ$mVh&37w)~Q7h1WpPG
z$uL4Wa9sZ)n5=H+$u0rX2^r0JK<V`E1p*Lbx+j?hqN=f@qkacMh(@AJbF;HZnca)x
zHOUn`9!WJA$uQCpG}|IV%s9)kVVUgzB^j+|qjS7eCW%a*z=jpLEF)KRW{&$t%yS=p
zaLd~Q`CM*`CK@Y!_cgcB#N$tn;w^9ZBTCx>3^4}R77$WwraaTxw*5DnNK6e%pn;&+
zMlu#gnXPIz$%wN={4!BO3e;E}u|k2QsUVg}p{biNS_XApW-V(FSR!G9R9QHP6@5AO
z_6n7x!Km^WMjZmnKyYQ0n3b(&2~l!{TPh;Y?YITBsD%XSoRyEK#ys!9oWAF{0r>LA
zUXPK2_PRn!x<0CT8?AbswcEt^wms!#^SO_<EMbGJL@o=8QAWqFeMX)qGx^sCAQ%o4
zaoW|8h6-!2Kb3+_5C)j`u4AGwG=MCn(Q$2vtYe3zV{yTuU<5Mvljs>hHK>#2hiG#n
zK?RM)BAgmcRWw4-ZOAqD|F)kYU<YW^?h4R#8_OjIBO5}3+>)XU4xQ7B-o63M70c-#
z?R@C?00@e$)v<8uu7IjWOv;SE!0-KJhij|K`_p~BUuBxUR?&i&3AUfi9v2)W@d=%m
z5!&r`$4d>aT#bE?J%Cvn5|!T%5B89)n@Hq(paf$bv5iI|o$_hY6R50fpCb%LH^$D+
zf2F0T(2r~?46|8;E!0W0%p5s{a?7RH=VB{WgxTGRP*Bs`a9xGjMgAc%HtG(YB9+9g
zV^zu(2GfCi9{%EMZeDCzTO>g%%`Ptr>0nmY+mvH9U|s&Hd%Qz#%Xx2$h60g#g=tAG
z{ptO?QL0=2mR%A2%50@XSxU?$c<~<VE*|SaquE4~q@%J%{d#msP%K0kLqpKH&Fa-7
zOz{>Y6-PMR2frcrd-Z4}OctjH;IXR3B^b>rdh$6WSRS5}WLCM*nHhqTffn&lp|97;
zA<Og`5%PqZ%%D=H6f@-|c7(EDyspIWbWAN#_v<Fs4iG?QVJz&1!-{ZCG@1G^(JZbh
ztPor=9xSyyZ>G|C{I=^ayr)vEee**%-B*(fy(`uf*<CG6PGhO+8;E+fWxIcS{lDzx
z8TR6bUm8M)S}jVx9_u8=0E8|h2k8Y&8lM(V8cC)w(i^7>HW3a-d2uSDOyO3OwH^v^
zKc>4%Ic?S88ck#}Il8$Xm{bJOZj!kzM%O1)Rs;!Br1UNlC^;BH&5%*7YWyt=tGdjt
zPp5)-<Oz%A;G#)FPBk>9e-3ga2t#33@t@;pA<HyE)#4%$pi`h5EyQvc2xfD$7!qId
z%`KN*DHHMsv~cV#N+_&8@yN9QhS6KU@#ymZkVrrclBYDvp@?$5f=Jw#FM~a~f6K{0
zv#G;k=_IK0QFRrABC^I61YBQ1e50eHw0ICr0vJzgXjB%tFS8+#VmH?Zhq|svO?rhU
z>{gkA;=)u2tit38%2X8r6D2x8IZYw;aDWce)~PgY{|RwNfZ%(u8IrdDTJhR-LufT@
zI>=r+LUxm40Au?qIPcs(W||GNT7te@R^yT2yGF<M3$kuHUu`rSyB^xUf3v8FKmMl&
z7k>8K;=gm#yZlGcM3U0N2<1p{#Tv~?C<2pOXOW<M9SyQwrTRe%CrE}d=)7Q_i?waQ
z6I)1<`I!<Zm6k|^3L@D7I9$9N>g9f7r<WJq02k|`QERiz6f}z-{lA0R`6Wi2StQk1
za&6WuYh6u36tzwR#O{b?(LirDf_x-|>cli^#U^H+9%CCF@RpZr^QPHee4z2mfz?B?
zlwP;!GA)cXSn|=p`eQajTW@-2vNxOD69@=-suwJ3vl^uX<b@cl`KU@_X%suwG@i}C
zQ{$*s$}}jGG%OzLImjp|@LyMK*#<Kxg-CuC#P|re&7e&OQ!g*0R$4@*G>`d%)0D$`
zwCW|a%oZcBviHv-L8H|uEfZz01EM2^5n;cOk7-y{h!eyL!Eq3f49reUINP`HeX`xM
zZ?SFft~1u2ZP<>UbdB2Q$Ho>epIK~*swg^!Dt-Kz_X7?t>g7WJ@SPCr9|&nAJrbJT
zU<xvoL=vE3ij0nqU_9qPrKP@;C)k%q^K^?IZF9I6it3?OE79#yN`qM%E4n+2eFUYg
z%}f&H2!R4ps_*qh%r4iU(`|YJqe`Mo_w|ufE1g&0g4{63mUrm1bCF8N=^^R_Z~+qs
zp7ENM#mTb1@b$t-&rf4#uG;?oYqqwZy}8(VHd6Z6tKRsRa-#7sQr%puCPMS)u3!6o
z;dr$2seiv_RV3v7LU6rkxk}BZ-IYR75?Yga-onuE5CZW6EFlbu&XMBKVR?ytLy!Qt
z<b-Oi%!so7BU$cC^5eGrfGCNyLEo@AH%m+H6KIgU;+GH=fdw95_b4!ZiU;>GvU^Fa
zNu06nY$S67<XZ;B)V<2m#L^?%esHbqwEyjz+kaj^kvm($@osqFCx3sv(l)MkS{0`F
z0;4T3YH?&}k%Nf=R9h0+n3_$G&}`^zltPTGOTx>+)XBA!u4-dHi7|?XrBObk{&ODx
zks9XbW~lqYj)(9&x|XR!Q<ctlE`g{mOya=qCq1jB*G^lpVt3DQ@13Q_(oRiD38Eub
z_wM?|*#G_Pw@N2-Ywy<p_|gq;CR@6~`#*X2uQU^PfAM{(b!VONuxi)Nko09XIc*4`
z1cYD$x*bNPQp1kN9`2|?wWiYp^kQ)BdY+;4?ivD=GnEo*k<biBrXviHzQxY{1dFoh
zH&hNu&HrprDl=@Fe7)Bj)%N5w+qXL{^VVcC@k3@q{XL(#(|f*d!X7aL{`H1;;?J-C
z)~|j4;Jts}pALyzG}pYuzu@V)B~v%uCEE#3@7S^HC6g1Asz>J6WS^*Hqz8ww@l_X6
z{&EOVIYdu<764mB(_neh9yiL1s8bz$BV>2LXd#!&=&B|@Ai%kMW_oIyBvi*f__?hv
zUVtH-=nnVaagE?Qt=E^!rJe)hQ%{A%;T`Y2;d}P`E_~_d8cpL90=<4vYO{7d{{=^6
zR&Qj@ZlrON2>>aB3v7}@d@J0lQqv7KJ=8ur#Y(+a-l@p)HcboMWwsi7uKL0~FZgYE
z;rTkyr{8r^p;B)=YzyKD-8m#zAE(q@qh<1ec)GAAo-CZsj%dL5uT7&lXSV7Kj$S*U
z2;P$|%X)%lYu<G{<D<9S`#XIOAv~W4yXwzgmvCKYl_xesmR0}dE#KZ*$BW~|@#1)K
e{2q`07GMA?4zCB|JFGAO0000<MNUMnLSTY_Edikb

literal 0
HcmV?d00001

diff --git a/resources/icons/Tapeti.Serilog.png b/resources/icons/Tapeti.Serilog.png
new file mode 100644
index 0000000000000000000000000000000000000000..53332f074e0d7ed19077d0119ee483a5e729804f
GIT binary patch
literal 6071
zcmV;o7f9%dP)<h;3K|Lk000e1NJLTq002M$002M;1^@s6s%dfF0000PbVXQnQ*UN;
zcVTj606}DLVr3vnZDD6+Qe|Oed2z{QJOBU}SxH1eRCwC#S_zaKWx2hzS9MqK>+CaG
zNJ0V$VF|(mV&E7+HWftRsVFL&%R|H`5L9GQg8~s;cn?$rMG=+79MKbvY>9y=A%rZ$
zB$*|%Pw&;WFYoI{J*WstBrHDuIdi&Cch%qZ-|zeGz29F2yfyxR59aSb;3a7Ry`1(M
z{eGGLzwcUB`3->vE&h8eZn-5WmCM0vF*ZE&Oz^(5&o2EL^w)jy3%+#CHNopK79MiQ
zFJ62t*L`Y9{?@DB6@M+(&A#Y;{OF^PeqF#{x^(H{zr6qU7tUa`viaqw*KfUJ#bxj9
z-jjLGI)0wGbYa`!pFMr?d#*lb|JZH?{-1qu+&kW}PZs-u_rJgS|Kg#@@?WFP`W_>I
z%S!>XbYgg9)@`3Z=d|;`^uxYan)k37-P6ir<}W(iS`K7c4|T)syXlhS7hH1F!}Yxa
zVAXGa^SWe1;M+kuAvxs<mytPsZgH%9_cuRx_QzE<wElz3Zhy&hKKAang=^!uFDgg}
zwx=V|i~=}5G-G@3j&tejZ|-ghydj3^I1pq(&*oxqoH}g7UNk;D`Rl2P(!zgsPHn3G
z?)GTxpab(Mw8s-DS3CqzVCl}KSDtZD_)P_XX4pYE7Jq8?yg9xLAGYTp5{@K?`Uh`c
ze&IV?{{Hwce)KdhCaafrsv+!`SC9`YFbod1!$FP2d-``x9=BH|aLu*X{!0sK5b7~|
zL8{AcS&geddgOOzbax)xJ!AUPb?f_BRth1R${n<GaMz!%KL5C*zHr;Bzj8uhqPnQF
zz2m@6ISfYh5O;ipB*5?llr#nt8WZdl0RO5Yba!>_^|@d8-zVzVUci3h&_fSdwR31!
z_i#Z+XD&}5wB~pA4_)}ROHRM^GdJCbd#<^d86Ve94+#<zmlU#fRR{qK*Ktv|Z0MF9
z^t9)9;@P1+2jH03NfQ5>3Ez2a``tb5pXg{y{d~Mw5bE_ZQi&M23F)IdcaD9X4jCyH
zi>as*Ju*Uz=PAyPZNu?=FpLjT;!&!Zm0YHC$D4`+UOXlX#g$=M`e~jNoplS8?n4NL
zqmjw+iBC0+OFTZ0zMrG;0s_y2z;p0C7hy$0O)tXr%x8~Va@5|*;3JPdx=$B3fBt;L
zV=wPjE?NHT;Fc?nzj}IC^yID2_D3v7gva?vXHw^#yfFQh@ro7qDphe_Ybzw#g;6sx
zLQCQq2OgDz<+6`2Irs9tGeVE<V*nZ)@k#(RhV5FtUG1HB4-Jl8=$0(lb`6}Uq;m1Z
z<)WheY|WYt#<Wac5<?v78l^u0Bno~r6CBqY*=r|w)v{%;S*n*Sm4Eu(rOQ`i<!v8Z
zna;*8aI8tjvJ3=H0P;&8P^02^O~xA;D-`3?qf&D<fomfaVxZM^@)1sbPkI4VUgkpf
z<ygOd{f3wOe*4hC<FYE2IL?JC(;__$oag6$v+|eilUn7c6}<+}w@C&Wn06IfZ3;o)
z1)?l&-E9D<C;$D|Z@h6s`85XN2Y20tHEY-2`LgcN_Nuu=?)hviL_rP+02Z9$&?5E!
z@Z8|;=LdG$qMCq6?5~$5V0jE=NwzX^p?8l;fG*_i2QFA}(~(CU(fw*IaKnZT-CLe}
z?jPoxGk0!(TU%Q{k?oxX{`X&Qj?XS%6+CkLMe8E5$RcZ?3|cgthEMc^8K=MVi0x}v
ztzYBv>|&00k&K0*4V6ei>Z50zc4X<nwf(yfKx1cSsK5V1Kkn~;HTM}7Klso?t4}%k
z<iGj6Z~OK;w{G72#oe8!uYcznO*cL%N&@_f3)Aw*DEp#OBVJ(qt$iZ{i(^g^&ukii
zVR4PUuKvqcJml{Y2keW{D6Ow9U;a{v#`a_$-7?pOVo_Zs<zRTGxtB+6wAItz;TymX
zi}B$4b@X&n6J<NpL*Ng4x*@X9#*<Gy^{xvqzW8tU{Z2mVq{VwOM<kIL1ShXb<l-cC
z4$?UliprOh)cx7u2YrD@YiF81lSu_a4O6u84FdpW!G_!KxZ~|d9(7dzGaENHKU=(b
z@d7H3-R7EeulTv|c-%KSd)mFWjtq(#3(bul{*zz*p|d;F&MUHoipAjm)x+Q;YJJI~
zo=tBU0R933Wx_#+9Cp~%XPt9SxnY8Gx!g^AGKVZkYsu#o@~zbQu|6b8Ib`8Mvp(CA
zGcFj}If|z?4?|3=7@0Ke?)ENoueQZs!%f)6*84FH*G=HuzdPsL^OgTZHW_<duWUcE
zufGURN}^gVdxlZrs#6?NSpl99ptl$H%<1{AYwvt`?3L!^UM~QA&)Z7>zizzl?m0hO
zwGqc3)_HJCR6W$vO(MJ&kn3ellS4QaL%nW5WF_cYjeD+lq<`mR^{F>30DC)5I<liZ
z+nPU_m%_;B(~x-&tZzXO7)YXsa5#j9R0h6(bX!tf_xxyW=bN@2eyJhy%BW4zHysPV
zd2AbYOo)hPJ0VgiQxOr_R2ub~jZ{=r(~0OkhtJHl{96HlfU7xL4UT7F!4aq8q1AmT
zxp7RNdnk0X2EA55hKMlVk_O9hS&n1&`?msMbZoNA3M8=P`-93DLQ^|X9vnx<?86aD
zXAp^sWRR#F!YVYw3V0s+UbVw-r17)mA0)kE4-A0wIW9P-P%R;oP$7Cln76PK@l+Cq
zVWVx%LX2+TLIhia@0c%ap|OzOv;aKxjgKT^G4-Ut)!$_p&WW55mZpkz&`ZM{LuND_
zdt@5|l|v-Nfy>RoWdBagn3l%CU=c}Gz}SfCz3Bk>{#EZ&QmNRLYDoNW;F~Sc2-%;Y
zL3{=RmW3Q{K`shR^lqY-*hbl(ge4}CY@Lm^jxJ2@9D^$IWSm?k5*9jW%C&DA4!HL#
zXEW(c<iC4*TCWf|zeSZrNP<8HC<=jd(b|!vR(A?pxAa1dNT}H+{J?`_RbkjA7^aTm
zxQ24YLQS)%eUO&ylMJ}^(<d@zT~CnacDCg5|1mZ)wkVU1XB^+r4c#3zO>Zplv7HcJ
zec88uHM%=<uDt0Z3`O|T0QQxo(imeJHAtKaPG}fb4~bX^HP4}XH;C|3aKau$LqlLP
z)ci06%qTkBXJcyD6rLYiPaR<dX5gOsi8B{nbIVWG4gX63-0-<mxJ0)5%=UcGNwuj#
zcVgGJX%frK>*;J&i{&cU+Sc0K+lvtkyROqrE~;C)Y_4|mr%(N*YuPu1B<bmkZhUFi
z`{V1+<VGikKhxgcc5O19;f;C?JjXQ`Uai!TPe;iE5DnI=SbD<o*xa`r4sRnjJ%ipY
zTTqx7LpYL#pJ~CcC*X-^i73+wG~Y`{M5}RMad@wt;Mcx%X0mJUqT8qKzv%Pn-1Gwy
zF=hVLcz>s*Rb@#8%d-M3YQSBh8&j_~_HrA0a<EJb<5Lx>rWpr>mGFlcMx6iN6OR}?
z{%x~IS3bU}dCTetSHF)tVs83ay<WdD9*<nm+Cqz`$SZ<^uq+|)48$XGa(g-~(s)~|
z!WBZ8bHGB1u#D%a-nWlTfg#XS0tb=WW5iqFSz$c)>=wu>fA5?bUCV#JzSrNYX6Q%P
zyyI>4K)OqAJ9K*6w1bdPQ>cz@LSgV}h(SOTcw{>R^bZVz4FsgKITXu7Flq7WR0nzo
zMw^*Hog2uuV|Z-XJN)2-HYCFG<E7FBGc>$o@%#hk&5Nokn@N+L5r9EJ=h7l7g)umG
z0dr=|L9MilB+W&oX2SAWaM5l=+7AY+#?ZTM3-aLr8`u06a}RzywvCv0a_t{6)VsO2
zV^-^u6?Z=}yvN<(&#zvh<`U8;GwJMQqs4lB*os1GnL{n?3``AgMhIoZ!ZFykfzg5O
zWIyY)P!FE#qqQZ0Lb-s+k`3FXKnpxAo}*MY2nYdTi6^TnlU~=+)lTLm9;Zkp2_6Qv
zUM51TARUQea(ooIY!n?WtuSj7sMaXEq&RG|iix6z(K3r@ZW^*}GwHkvDiZ_PH8g>-
zf{D?|@jktzExqgU-W_{Pf<L|fg#Ei)l0Oz1W1hmgj9;AsPYf%@6j&t=Qe*Qmnjo{m
z!SxMj6*3+kEtKVO^wEp(*dwbkGCl<*nnXllF;yuy0id1*uA^hd^w}8MwH>XrxLAlK
z-iUyqbe9<q1p+dl+AmHHBAW<9Aje1TE&@1Eqfu0i0H((wq;QDVDwynj3LDow+Q>tK
z&nF(z$TRUyA{M>ywufGR@h=I$PnVy}wWp%D$0QuU@?lD47b@9Gn--c1GvvXm2#1L1
zYzr!t1H(AffW)zRb050*n}wYNeV8h1<i*=DHCaN4=fHb5qOk<LkcXB`7CwQwaQ=QY
zuL53@iA2c6IK<{g5xi9b8zSJ6aRN-E&W^rg0_yV>1Plk26RGwC^8FTp7Qysc8H_*i
zB=rCqrm7Y!`p)*TYX1d2zum2UiGR3dm1{XI7RI7VVF<EJc2kHTnu=huHrT8fmza*H
z7L;QH0>OOY;v5?arS<UOE@;%LNue+tBBgX(ghh+!%tR?ZK4RGf63GNYvVvqX1)bzf
zcYH_;ozGZQ?>eGk83MUFnPm{jQ35DLzo&rXML0eK!W$e%fTmiYB)R5q#u5pbHf5J@
zH;LHu@VjNVJRI!tme>O~oT*akd_}7k*(AvcFDejanNal*$>iX&FGNh!G^$gZKw#*f
zgoMaYB{}f?#zi#t?3;IX2_T&yBQq`w&E7pv07NO>6O;w4D8UIxzvU1jYJ}3<YA%we
z?nMad#1%9jk*cDmDbgzH4vP?FoNc?XE$aU{9!6bj&X-Ilkj@dXVF5msk<WU=yS+2@
zmp8w<`3yOi&90DGb4J5`jgHr`{+V99=ftB(+QwnBQTQ%{kl<3vQ#!kD<B29BCXFP}
zgu*&VM8haitC~qr#HmCYWg>(Gh|w6L`8<)PfM`64x^BTVOwx6pYFPq9B@!l(%Hz8*
zy)8?<y+BH$QB-LTYH=AV1IFi3q^vaRMMQ`r{9*w)I*yKj6tNK}I;YCV#=aofF{*Fb
zZ2-Rg*%Q!{mzL&}+;tHtSZLR3RJ(ONxO!ud$z?AyY~~<dP|s1=2t}t+`xJTlF^gUs
z04U)wAx?HRB%w?-*q%(nB@j9&?S1Om^IaXtkTiO}3zq8GqtdZy!68KjPv>#u89-`K
zBbM(Xo2x1Uw21<|Dw(Q?N}#*otJMFyjSK;GfG*ix2D<KIsz|}egb*igNs<h9Eoen+
zTL(r9rPQxCJ-&MYD6BC%8cyCPi=t|g%rqAG;BTMyT~W9=)z*3&rRi~kq@2UJjbsjJ
z!3q%{(|j1gah#@?>YOnf&p-7jM#zwe^m%t@3$b+_@oWnOCE66*h^jWrr%s+gq`Gc!
zgh|njQfJqAq@^X_j!ZHPt6qT1)QD&)bNCQShEHCf7F(_$Ox+y|0ae|B?+cV&#6Lug
zTFoP;NJ`?@Ff-{hohkW&HMbsn(}ZEK;25bmGBv@Zlnk#sB*&s`pZoa-f){Ph24_S<
zvRW%sT9TIj?vc$X*6bf<rYqkWDHlnW;-hi8_<-sz7Hxr6uOmUEBT|hv>d_~HqC$k(
z)dii7nLWFQQrw_O#SqT4q0x{xdi97JCKe|TKyy_JlQ8QQwB)jgQ+Whlg0jkoPMN_7
zX-H~-GWmL)IAn@^hDtmkCekRENQx=tIqC@cM)CR_eWqh@l61djVQvQjNLd&S`{A&_
zEQ=(PpC&X5bMn&}pN%O+BM64e+WPNbcgh3hLiI=gb>r`=e7<%1oC0-M;{!vOtTYTn
ztzx+Tm#@2H8~wsIJp8RLgh;DduA#>|5u*&|&y1{)7qH0q81$oRB8i^X7`b2z;c$d5
zPDF%K*r-#jhh#dB(p@AuHLCE<I@0MZxw#ftqzJ5AC+4;(x(!05iXehyNqQ#;C|(Jn
zYVs&lB>FA`yD~*xpH2!A5Kq`t4u122sH7%Q`e(tb3QU2rivB!L3fYz!suU&wnVbT-
z(R?&}JY&_Dup#!4AFVj&5}qJ`R0>DmBZR`@hP6W`<@f1#JvsGP5|KrPcuFEUWKpV>
zp~f2WWl~Sx*m5#auj{a>bmFA*5pgC3g{2x7Ao~pkX&4<5#fe?06M(Ul1g$(l=TbJv
zN$Td>;E}EiT%Ei^9j;L#LGfV;1gt>Gqwu6E4El@Y0QnRNX@DK%FkPLL#vwywH3bL_
z4>nAsz2><x=FaPap}FKBTgeepH_6KAd%ldr4sN4Nb757A(5FgbOjXY7?c2`qy5-%b
z)wSmyU$=b;E3m8n=dtl8{<8R=+;|?55ZPOjL7yU&C4wtd$()2#Sfq6}5mZA*6>3*W
z{lJCeM21o5biwpnRNE#3)<A-opHc$F;v^BF05#JAj~4HTTIoEt*~_!OOpEoQRUIlb
z0rf&a{@=sM*d#@qvWTlv$vITBRO?~_EGsn|AnJ~&EHt!cROHkUD*Z#K7U~#&wvXCq
zIhdNNj#-v7@u>Evj@ez&q+YYhW!mV|sN^H^0k7B$t-SH9L~ACoMV6TysTXY0W-&qz
zkS@fenvaM?ELx#yO=Fof0x^b4xkLtKfDB7O^{h}71T-F3G+dK1C<!$;6Kt%9j!nZM
z2U9Cep<0|kxj2TgT|*>?V=!t(7?wei7n_@%aWYz3af(n5njm^y7%KG(xu}Gh`51v%
zCU88+oQaYCesA5nZO=G{d$a2X_syC+-*i1a;hWVP`ufJt9iFJOBFlQF$bIe=_XBoK
z=%svn_q||ip9o1rdPHchMkz?C#1a9T7E965p~SL{yR@Y5#1qt)M{?vA1G3HGRtRE%
zYPCpikEB$|kg+0nXHy?R(&kVmF}zAZ0ZFmp^;wKeRiTsH3>b<k5oM~ajYzfJeDqDB
z0~Km{yQUqCWGY4;qDBCYqkqTNpkAIBDCy(h%lEYWF1r8Bbr&yN>AbMH*t|DV{O;u^
zeT<K5cW^apt{4xE9elvtU+&hu!Hqv#Hd74+e`Ne1QmT+<lilS)5hAoY<+*{b?k>o&
zJZvTmj+`TjLzCq>>KhaSz$Z?qR7(_5s(&>@=MwqRvGfKJB2tZf!^G$aS?UIXD#R;|
z5+X&Q0+*?KWGH<KyPl`WZX;q%VAj0(NMt*RZz&*_9+W5hC)ck2)fafr`QfrV|4`eL
zovq!zIlAMwU%gIn%qu*jOesE2(Pk)WF{H^NEAb9g435~CG@Cp^UDK&i3Q=TzBD^dt
zow$~ytD<cuVvInuC6dob<33O09wEj?he`L9riW;BbcUrv5{2exJ^@i3AHa^y&jhxi
zSEo&%zPY8l_1>a3xk(a|4C}F#ZO{F&@8j3pQ{0=ay?+4UTi3sv*wSY%zUuzJX(sN!
z^`hjw181!f-Rdk(pQ0wm0TYUYQR2|uFv{gBo_=agQw=IrojgD*I_DlhztDJgjfG5d
zCX$5OL};eRlOvRgzS-t}f=#m6XsA3QwZ?msq%uuSQ$z1{t>O%9UAN9NtXmR^_`{S9
zwe!DpZ}4hu!oFk%eE0gZ@Zl@&`G?ORd+4j}sSvwD@~w9@E_i5k($Xz|()E;~r=NcA
zkb(XIF(Brb_y$q&NOg8&;W4L>{AD4Na<BpW0st<Hx=H0p_E;-TphoJ@FhXt<3<KG0
zS{EhuQ3l@q!$X6sIi}M0scTpI*au^epAUHC?q!Vc87GuV#g-jA2RDYp;ioUW{z3Pm
zQx3mYtD9Fc<n<NKq1p|=k$*_fUPv{&kc<;g01#!+0_(&f4J&L^NYhPfdPw`oDVA&1
z(k6lDS4)z7pJixUF8{^@`+OVzReM0<i|3u1FW0m+F2nYaI|t|MJ4tGmN$H#%OXcUp
z68Zh8BkE}Q*Sc9BwT#-hr&o6fOz@0h+Z)Jijrm?+UUu_Cujze=SM>>z%RjI*?)%=%
xfUSpYyY{D>f4r%Nx5iuJt?|})1CRd`U;v{B%ZObvNJIbt002ovPDHLkV1oLuoecm0

literal 0
HcmV?d00001


From c5f2c4ba89ace3b5c1e4db0266328f50c84d64aa Mon Sep 17 00:00:00 2001
From: Mark van Renswoude <mark@x2software.net>
Date: Wed, 19 Dec 2018 22:17:04 +0100
Subject: [PATCH 6/7] Typo in AppVeyor.yml

---
 appveyor.yml | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/appveyor.yml b/appveyor.yml
index bbf7f81..d2d5812 100644
--- a/appveyor.yml
+++ b/appveyor.yml
@@ -18,7 +18,7 @@ after_build:
   - cmd: appveyor PushArtifact "Tapeti.DataAnnotations.%GitVersion_NuGetVersion%.nupkg"
   - cmd: nuget pack Tapeti.Flow\Tapeti.Flow.nuspec -version "%GitVersion_NuGetVersion%" -prop "target=%CONFIGURATION%"
   - cmd: appveyor PushArtifact "Tapeti.Flow.%GitVersion_NuGetVersion%.nupkg"
-  - cmd: nuget pack Tapeti.Flow\SQL.Tapeti.Flow.SQL.nuspec -version "%GitVersion_NuGetVersion%" -prop "target=%CONFIGURATION%"
+  - cmd: nuget pack Tapeti.Flow.SQL\Tapeti.Flow.SQL.nuspec -version "%GitVersion_NuGetVersion%" -prop "target=%CONFIGURATION%"
   - cmd: appveyor PushArtifact "Tapeti.Flow.SQL.%GitVersion_NuGetVersion%.nupkg"
   - cmd: nuget pack Tapeti.SimpleInjector\Tapeti.SimpleInjector.nuspec -version "%GitVersion_NuGetVersion%" -prop "target=%CONFIGURATION%"
   - cmd: appveyor PushArtifact "Tapeti.SimpleInjector.%GitVersion_NuGetVersion%.nupkg"

From 91ce1555d5bb694421991e6af417164a7b6879cd Mon Sep 17 00:00:00 2001
From: Mark van Renswoude <mark@x2software.net>
Date: Fri, 21 Dec 2018 10:49:30 +0100
Subject: [PATCH 7/7] Fixed NRE with async methods returning a message

---
 Tapeti/Default/PublishResultBinding.cs | 10 ++++++++++
 Test/MarcoController.cs                |  3 ++-
 2 files changed, 12 insertions(+), 1 deletion(-)

diff --git a/Tapeti/Default/PublishResultBinding.cs b/Tapeti/Default/PublishResultBinding.cs
index 38d5ff8..d02d087 100644
--- a/Tapeti/Default/PublishResultBinding.cs
+++ b/Tapeti/Default/PublishResultBinding.cs
@@ -38,6 +38,16 @@ namespace Tapeti.Default
         }
 
 
+
+        // ReSharper disable once UnusedMember.Local - used implicitly above
+        private static async Task PublishGenericTaskResult<T>(IMessageContext messageContext, object value) where T : class
+        {
+            var message = await (Task<T>)value;
+            if (message != null)
+                await Reply(message, messageContext);
+        }
+
+
         private static Task Reply(object message, IMessageContext messageContext)
         {
             var publisher = (IInternalPublisher)messageContext.DependencyResolver.Resolve<IPublisher>();
diff --git a/Test/MarcoController.cs b/Test/MarcoController.cs
index da2ddab..4ced01e 100644
--- a/Test/MarcoController.cs
+++ b/Test/MarcoController.cs
@@ -120,9 +120,10 @@ namespace Test
          * This will automatically include the correlationId in the response and
          * use the replyTo header of the request if provided.
          */
-        public PoloConfirmationResponseMessage PoloConfirmation(PoloConfirmationRequestMessage message)
+        public async Task<PoloConfirmationResponseMessage> PoloConfirmation(PoloConfirmationRequestMessage message)
         {
             Console.WriteLine(">> PoloConfirmation (returning confirmation)");
+            await Task.Delay(100);
 
             return new PoloConfirmationResponseMessage
             {