Merge pull request #179 from akkadotnet/cleanup-merge

v1.4.11 Release

Author: Aaronontheweb

RELEASE_NOTES.md

@@ -1,3 +1,2 @@
-#### 1.4.10 August 21 2020 ####
-* Upgrades to Akka.NET v1.4.10
-* Resolves high memory consumption issues with the `SqlJournal` as a result of https://github.com/akkadotnet/akka.net/issues/4524
+#### 1.4.11 November 11 2020 ####
+* Upgrades to [Akka.NET v1.4.11](https://github.com/akkadotnet/akka.net/releases/tag/1.4.11)

src/Akka.Persistence.SqlServer.Tests/Batching/BatchingSqlServerJournalPerfSpec.cs

@@ -0,0 +1,56 @@
+// -----------------------------------------------------------------------
+// <copyright file="BatchingSqlServerJournalPerfSpec.cs" company="Akka.NET Project">
+//      Copyright (C) 2013 - 2020 .NET Foundation <https://github.com/akkadotnet/akka.net>
+// </copyright>
+// -----------------------------------------------------------------------
+
+using System;
+using Akka.Configuration;
+using Akka.Persistence.TestKit.Performance;
+using Xunit;
+using Xunit.Abstractions;
+
+namespace Akka.Persistence.SqlServer.Tests
+{
+    [Collection("SqlServerSpec")]
+    public class BatchingSqlServerJournalPerfSpec : JournalPerfSpec
+    {
+        private static Config InitConfig(SqlServerFixture fixture)
+        {
+            //need to make sure db is created before the tests start
+            DbUtils.Initialize(fixture.ConnectionString);
+            
+            var specString = $@"
+                akka.persistence {{
+                    publish-plugin-commands = on
+                    journal {{
+                        plugin = ""akka.persistence.journal.sql-server""
+                        sql-server {{
+                            class = ""Akka.Persistence.SqlServer.Journal.BatchingSqlServerJournal, Akka.Persistence.SqlServer""
+                            plugin-dispatcher = ""akka.actor.default-dispatcher""
+                            table-name = EventJournal
+                            schema-name = dbo
+                            auto-initialize = on
+                            connection-string = ""{DbUtils.ConnectionString}""
+                        }}
+                    }}
+                }}";
+
+            return ConfigurationFactory.ParseString(specString);
+        }
+
+        public BatchingSqlServerJournalPerfSpec(ITestOutputHelper output, SqlServerFixture fixture)
+            : base(InitConfig(fixture), "BatchingSqlServerJournalPerfSpec", output)
+        {
+            EventsCount = 1000;
+            ExpectDuration = TimeSpan.FromMinutes(10);
+            MeasurementIterations = 1;
+        }
+
+        protected override void Dispose(bool disposing)
+        {
+            base.Dispose(disposing);
+            DbUtils.Clean();
+        }
+    }
+}

src/Akka.Persistence.SqlServer.Tests/SqlServerJournalPerfSpec.cs

@@ -0,0 +1,56 @@
+// -----------------------------------------------------------------------
+// <copyright file="SqlServerJournalPerfSpec.cs" company="Akka.NET Project">
+//      Copyright (C) 2013 - 2020 .NET Foundation <https://github.com/akkadotnet/akka.net>
+// </copyright>
+// -----------------------------------------------------------------------
+
+using System;
+using Akka.Configuration;
+using Akka.Persistence.TestKit.Performance;
+using Xunit;
+using Xunit.Abstractions;
+
+namespace Akka.Persistence.SqlServer.Tests
+{
+    [Collection("SqlServerSpec")]
+    public class SqlServerJournalPerfSpec : JournalPerfSpec
+    {
+        private static Config InitConfig(SqlServerFixture fixture)
+        {
+            //need to make sure db is created before the tests start
+            DbUtils.Initialize(fixture.ConnectionString);
+            
+            var specString = $@"
+                akka.persistence {{
+                    publish-plugin-commands = on
+                    journal {{
+                        plugin = ""akka.persistence.journal.sql-server""
+                        sql-server {{
+                            class = ""Akka.Persistence.SqlServer.Journal.SqlServerJournal, Akka.Persistence.SqlServer""
+                            plugin-dispatcher = ""akka.actor.default-dispatcher""
+                            table-name = EventJournal
+                            schema-name = dbo
+                            auto-initialize = on
+                            connection-string = ""{DbUtils.ConnectionString}""
+                        }}
+                    }}
+                }}";
+
+            return ConfigurationFactory.ParseString(specString);
+        }
+
+        public SqlServerJournalPerfSpec(ITestOutputHelper output, SqlServerFixture fixture)
+            : base(InitConfig(fixture), "SqlServerJournalPerfSpec", output)
+        {
+            EventsCount = 1000;
+            ExpectDuration = TimeSpan.FromMinutes(10);
+            MeasurementIterations = 1;
+        }
+
+        protected override void Dispose(bool disposing)
+        {
+            base.Dispose(disposing);
+            DbUtils.Clean();
+        }
+    }
+}

src/common.props

@@ -11,8 +11,8 @@
   </PropertyGroup>
   <PropertyGroup>
     <XunitVersion>2.4.1</XunitVersion>
-    <AkkaVersion>1.4.10</AkkaVersion>
-    <TestSdkVersion>16.7.1</TestSdkVersion>
+    <AkkaVersion>1.4.11</AkkaVersion>
+    <TestSdkVersion>16.8.0</TestSdkVersion>
     <NetCoreTestVersion>netcoreapp3.1</NetCoreTestVersion>
     <NetFrameworkTestVersion>net461</NetFrameworkTestVersion>
     <NetStandardLibVersion>netstandard2.0</NetStandardLibVersion>