fix: 修复 server 关闭服务器后，如果等待消息结束过程中，新消息将阻塞的问题

kercylan98 · Sep 8, 2023 · 19df61b · 19df61b
1 parent 6c882ed
commit 19df61b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/server/server.go b/server/server.go
@@ -573,7 +573,7 @@ func (slf *Server) ShuntChannelFreed(channelGuid int64) {
 
 // pushMessage 向服务器中写入特定类型的消息，需严格遵守消息属性要求
 func (slf *Server) pushMessage(message *Message) {
-	if slf.messagePool.IsClose() || slf.isShutdown.Load() || !slf.OnMessageExecBeforeEvent(message) {
+	if slf.messagePool.IsClose() || !slf.OnMessageExecBeforeEvent(message) {
 		slf.messagePool.Release(message)
 		return
 	}