From f5ed0be023a9df7d6e9eaa25b2056aa6cd9a471b Mon Sep 17 00:00:00 2001
From: Gordon <1432970085@qq.com>
Date: Fri, 23 Dec 2022 16:09:59 +0800
Subject: [PATCH] callback update

---
 internal/msg_transfer/logic/modify_msg_handler.go | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/internal/msg_transfer/logic/modify_msg_handler.go b/internal/msg_transfer/logic/modify_msg_handler.go
index 27764095c..782c6fcc0 100644
--- a/internal/msg_transfer/logic/modify_msg_handler.go
+++ b/internal/msg_transfer/logic/modify_msg_handler.go
@@ -9,6 +9,7 @@ import (
 	"Open_IM/pkg/common/log"
 	pbMsg "Open_IM/pkg/proto/msg"
 	server_api_params "Open_IM/pkg/proto/sdk_ws"
+	"Open_IM/pkg/utils"
 	"encoding/json"
 	"github.com/Shopify/sarama"
 
@@ -54,6 +55,10 @@ func (mmc *ModifyMsgConsumerHandler) ModifyMsg(cMsg *sarama.ConsumerMessage, msg
 	}
 	log.Debug(msgFromMQ.TriggerID, "proto.Unmarshal MsgDataToMQ", msgFromMQ.String())
 	for _, msgDataToMQ := range msgFromMQ.MessageList {
+		isReactionFromCache := utils.GetSwitchFromOptions(msgDataToMQ.MsgData.Options, constant.IsReactionFromCache)
+		if !isReactionFromCache {
+			continue
+		}
 		if msgDataToMQ.MsgData.ContentType == constant.ReactionMessageModifier {
 			notification := &base_info.ReactionMessageModifierNotification{}
 			if err := json.Unmarshal(msgDataToMQ.MsgData.Content, notification); err != nil {