@@ -122,7 +122,7 @@ func (messageQueue *MessageQueue) Subscribe(group string, topic string, handler
if !ok {
err := errors.New("数据不存在")
logger.GetInstance().Error(err)
- return errors.New("数据不存在")
+ return err
}
event, err := data_protocol.UnmarshalJsonCloudEvent([]byte(data))