fix send msg get nil reply

UnderTreeTech · Mar 8, 2022 · eebcf35 · eebcf35
1 parent 17ff6c8
commit eebcf35
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/pkg/broker/rocketmq/interceptor.go b/pkg/broker/rocketmq/interceptor.go
@@ -45,8 +45,12 @@ func producerMetricInterceptor(pc *ProducerConfig) primitive.Interceptor {
 		if err != nil {
 			errmsg = err.Error()
 		}
-		duration := time.Since(now).Seconds()
 
+		if realReply == nil || realReply.MessageQueue == nil {
+			return err
+		}
+
+		duration := time.Since(now).Seconds()
 		fields := make([]log.Field, 0, 5)
 		fields = append(
 			fields,