Bläddra i källkod

fix: 修复TenantActor

lijian 2 år sedan
förälder
incheckning
da8b75a0a4
1 ändrade filer med 7 tillägg och 8 borttagningar
  1. 7 8
      pkg/ruleEngine/mailbox.go

+ 7 - 8
pkg/ruleEngine/mailbox.go

@@ -206,12 +206,11 @@ func (m *MailBox) BroadcastChildren(msg protocol.ActorMsg) error {
 }
 
 func (m *MailBox) destroy() error {
-	return m.dispatcher.Submit(func() {
-		m.highPriorityMessages.Close()
-		m.normalPriorityMessages.Close()
-		m.setReadyStat(NOTREADY)
-		if err := m.actor.Destroy(); err != nil {
-			server.Log.Warnf("Failed to destroy actor :%s, err :%s", m.id, err.Error())
-		}
-	})
+	m.highPriorityMessages.Close()
+	m.normalPriorityMessages.Close()
+	m.setReadyStat(NOTREADY)
+	if err := m.actor.Destroy(); err != nil {
+		server.Log.Warnf("Failed to destroy actor :%s, err :%s", m.id, err.Error())
+	}
+	return nil
 }