From 6b451c52ff03cfa5605876fc5d060f75837ad65f Mon Sep 17 00:00:00 2001 From: Aaron Stannard Date: Wed, 10 Jan 2024 12:39:01 -0600 Subject: [PATCH] upgraded to Akka.NET v1.5.15 --- src/Directory.Build.props | 6 +++--- .../SqlSharding.Host/Actors/ProductTotalsActor.cs | 4 ++-- .../SqlSharding.Shared/Sharding/ProductMessageRouter.cs | 4 ---- 3 files changed, 5 insertions(+), 9 deletions(-) diff --git a/src/Directory.Build.props b/src/Directory.Build.props index 5d3352a..d031b36 100644 --- a/src/Directory.Build.props +++ b/src/Directory.Build.props @@ -16,9 +16,9 @@ net6.0 2.4.2 17.6.0 - 1.5.7 - 1.3.1 - 1.5.5 + 1.5.15 + 1.3.2 + 1.5.15 [7.0.0,) diff --git a/src/clustering/sharding-sqlserver/SqlSharding.Host/Actors/ProductTotalsActor.cs b/src/clustering/sharding-sqlserver/SqlSharding.Host/Actors/ProductTotalsActor.cs index dcb413a..5bd6c28 100644 --- a/src/clustering/sharding-sqlserver/SqlSharding.Host/Actors/ProductTotalsActor.cs +++ b/src/clustering/sharding-sqlserver/SqlSharding.Host/Actors/ProductTotalsActor.cs @@ -70,8 +70,8 @@ async Task ReplyToSender() await Task.Delay(1); return response; } - - ReplyToSender().PipeTo(Sender, failure: ex => new Status.Failure(ex)); + var sender = Sender; + ReplyToSender().PipeTo(sender, failure: ex => new Status.Failure(ex)); } diff --git a/src/clustering/sharding-sqlserver/SqlSharding.Shared/Sharding/ProductMessageRouter.cs b/src/clustering/sharding-sqlserver/SqlSharding.Shared/Sharding/ProductMessageRouter.cs index 7edf4ee..e0b0b2d 100644 --- a/src/clustering/sharding-sqlserver/SqlSharding.Shared/Sharding/ProductMessageRouter.cs +++ b/src/clustering/sharding-sqlserver/SqlSharding.Shared/Sharding/ProductMessageRouter.cs @@ -15,10 +15,6 @@ public sealed class ProductMessageRouter : HashCodeMessageExtractor return productId.ProductId; } - // need this for remember-entities - if (message is ShardRegion.StartEntity se) - return se.EntityId; - return null; } } \ No newline at end of file