v0.7.2 Release

RELEASE_NOTES.md

@@ -1,5 +1,4 @@
-#### 0.7.1 December 15 2020 ####
+#### 0.7.2 January 08 2021 ####
 **Release of Akka.Persistence.Azure**
 
-- Upgraded to [Akka.NET v1.4.12](https://github.com/akkadotnet/akka.net/releases/tag/1.4.12)
-- Added backoff/retry mechanism for `AzureSnapshotStore`
+- Upgraded to [Akka.NET v1.4.14](https://github.com/akkadotnet/akka.net/releases/tag/1.4.14)

build.ps1

@@ -140,7 +140,7 @@ if (Get-Command signclient -ErrorAction SilentlyContinue) {
 else{
     $SignClientFolder = Join-Path $ToolPath "signclient"
     Write-Host "SignClient not found. Installing to ... $SignClientFolder"
-    dotnet tool install SignClient --version 1.0.82 --tool-path "$SignClientFolder"
+    dotnet tool install SignClient --version 1.2.109 --tool-path "$SignClientFolder"
 }
 
 ###########################################################################

build.sh

@@ -112,7 +112,7 @@ fi
 # INSTALL SignTool
 ###########################################################################
 if [ ! -f "$SIGNTOOL_EXE" ]; then
-    "$SCRIPT_DIR/.dotnet/dotnet" tool install SignClient --version 1.0.82 --tool-path "$SIGNCLIENT_DIR"
+    "$SCRIPT_DIR/.dotnet/dotnet" tool install SignClient --version 1.2.109 --tool-path "$SIGNCLIENT_DIR"
     if [ $? -ne 0 ]; then
         echo "SignClient already installed."
     fi

src/Akka.Persistence.Azure.Tests/Akka.Persistence.Azure.Tests.csproj

@@ -7,7 +7,7 @@
 
   <ItemGroup>
     <PackageReference Include="Akka.Persistence.TCK" Version="$(AkkaVersion)" />
-    <PackageReference Include="FluentAssertions" Version="5.10.3" />
+    <PackageReference Include="FluentAssertions" Version="$(FluentAssertionsVersion)" />
     <PackageReference Include="Microsoft.NET.Test.Sdk" Version="$(TestSdkVersion)" />
     <PackageReference Include="xunit" Version="2.4.1" />
     <PackageReference Include="xunit.runner.visualstudio" Version="2.4.3">

src/Akka.Persistence.Azure.Tests/AzurePersistenceConfigSpec.cs

@@ -10,7 +10,6 @@
 using Akka.Persistence.Azure.Query;
 using Akka.Persistence.Azure.Snapshot;
 using FluentAssertions;
-using FluentAssertions.Equivalency;
 using Xunit;
 
 namespace Akka.Persistence.Azure.Tests
@@ -98,8 +97,7 @@ public void ShouldThrowArgumentExceptionForIllegalTableNames(string tableName, s
                         table-name = " + tableName + @" 
                     }").WithFallback(AzurePersistence.DefaultConfig)
                         .GetConfig("akka.persistence.journal.azure-table"));
-
-            createJournalSettings.Should().Throw<ArgumentException>(reason);
+            createJournalSettings.ShouldThrow<ArgumentException>(reason);
         }
 
         [Theory]
@@ -115,7 +113,7 @@ public void ShouldThrowArgumentExceptionForIllegalContainerNames(string containe
                     }").WithFallback(AzurePersistence.DefaultConfig)
                         .GetConfig("akka.persistence.snapshot-store.azure-blob-store"));
 
-            createSnapshotSettings.Should().Throw<ArgumentException>(reason);
+            createSnapshotSettings.ShouldThrow<ArgumentException>(reason);
         }
     }
 }

src/Akka.Persistence.Azure/Journal/AzureTableStorageJournal.cs

@@ -173,7 +173,8 @@ public override async Task ReplayMessagesAsync(
                             deserialized.Manifest,
                             deserialized.IsDeleted,
                             ActorRefs.NoSender,
-                            deserialized.WriterGuid);
+                            deserialized.WriterGuid,
+                            timestamp: savedEvent.UtcTicks);
 
                     if (_log.IsDebugEnabled && _settings.VerboseLogging)
                     {
@@ -831,7 +832,8 @@ private async Task<long> ReplayTaggedMessagesAsync(
                             deserialized.Manifest,
                             deserialized.IsDeleted,
                             ActorRefs.NoSender,
-                            deserialized.WriterGuid);
+                            deserialized.WriterGuid,
+                            timestamp: entry.UtcTicks);
 
                     foreach (var adapted in AdaptFromJournal(persistent))
                     {

src/Akka.Persistence.Azure/Query/Publishers/AbstractEventsByPersistenceIdPublisher.cs

@@ -83,7 +83,8 @@ protected Receive Replaying(int limit)
                         offset: new Sequence(seqNr),
                         persistenceId: PersistenceId,
                         sequenceNr: seqNr,
-                        @event: replayed.Persistent.Payload));
+                        @event: replayed.Persistent.Payload,
+                        timestamp: replayed.Persistent.Timestamp));
                     CurrentSequenceNr = seqNr + 1;
                     Buffer.DeliverBuffer(TotalDemand);
                 })

src/Akka.Persistence.Azure/Query/Publishers/AbstractEventsByTagPublisher.cs

@@ -68,6 +68,7 @@ protected Receive Replaying(int limit)
                         offset: new Sequence(replayed.Offset),
                         persistenceId: replayed.Persistent.PersistenceId,
                         sequenceNr: replayed.Persistent.SequenceNr,
+                        timestamp: replayed.Persistent.Timestamp,
                         @event: replayed.Persistent.Payload));
 
                     CurrentOffset = replayed.Offset;

src/common.props

@@ -16,7 +16,8 @@
   </PropertyGroup>
   <PropertyGroup>
     <XunitVersion>2.4.1</XunitVersion>
-    <AkkaVersion>1.4.12</AkkaVersion>
+    <AkkaVersion>1.4.14</AkkaVersion>
+    <FluentAssertionsVersion>4.14.0</FluentAssertionsVersion>
     <TestSdkVersion>16.8.3</TestSdkVersion>
     <NetCoreTestVersion>netcoreapp3.1</NetCoreTestVersion>
     <NetFrameworkTestVersion>net461</NetFrameworkTestVersion>