Update manager.go

fix ActorManagerContext DeactivateActor
wXwcoder · Feb 19, 2024 · 2bc9b71 · 2bc9b71
1 parent b787952
commit 2bc9b71
Showing 1 changed file with 1 addition and 11 deletions.
diff --git a/actor/manager/manager.go b/actor/manager/manager.go
@@ -164,8 +164,7 @@ func (m *DefaultActorManagerContext) InvokeMethod(ctx context.Context, actorID,
 	return rspData, actorErr.Success
 }
 
-// DeactivateActor removes actor from actor manager.
-func (m *DefaultActorManager) DeactivateActor(actorID string) actorErr.ActorErr {
+func (m *DefaultActorManagerContext) DeactivateActor(_ context.Context, actorID string) actorErr.ActorErr {
 	actor, ok := m.activeActors.Load(actorID)
 	if !ok {
 		return actorErr.ErrActorIDNotFound
@@ -175,15 +174,6 @@ func (m *DefaultActorManager) DeactivateActor(actorID string) actorErr.ActorErr
 	return actorErr.Success
 }
 
-func (m *DefaultActorManagerContext) DeactivateActor(_ context.Context, actorID string) actorErr.ActorErr {
-	_, ok := m.activeActors.Load(actorID)
-	if !ok {
-		return actorErr.ErrActorIDNotFound
-	}
-	m.activeActors.Delete(actorID)
-	return actorErr.Success
-}
-
 // InvokeReminder invoke reminder function with given params.
 func (m *DefaultActorManagerContext) InvokeReminder(ctx context.Context, actorID, reminderName string, params []byte) actorErr.ActorErr {
 	if m.factory == nil {