Skip to content

Commit c4e396b

Browse files
committed
fixed bugs with StartEntity
1 parent e71de86 commit c4e396b

File tree

2 files changed

+3
-1
lines changed

2 files changed

+3
-1
lines changed

src/contrib/cluster/Akka.Cluster.Sharding/ClusterSharding.cs

-1
Original file line numberDiff line numberDiff line change
@@ -71,7 +71,6 @@ public ExtractorAdapter(IMessageExtractor underlying)
7171
{
7272
return message switch
7373
{
74-
StartEntity se => se.EntityId,
7574
ShardingEnvelope se => se.EntityId,
7675
_ => _underlying.EntityId(message)
7776
};

src/contrib/cluster/Akka.Cluster.Sharding/ShardRegion.cs

+3
Original file line numberDiff line numberDiff line change
@@ -605,6 +605,9 @@ protected override bool Receive(object message)
605605
case RestartShard restart:
606606
DeliverRestartShard(restart, Sender);
607607
return true;
608+
case StartEntity se:
609+
DeliverMessage(se.EntityId, message, Sender);
610+
return true;
608611
default:
609612
var entityId = _messageExtractor.EntityId(message);
610613
if (entityId is null)

0 commit comments

Comments
 (0)