diff --git a/internal/util/mqclient/rmq_producer.go b/internal/util/mqclient/rmq_producer.go index ef1a613298..7ca9dba225 100644 --- a/internal/util/mqclient/rmq_producer.go +++ b/internal/util/mqclient/rmq_producer.go @@ -19,6 +19,7 @@ import ( var _ Producer = (*rmqProducer)(nil) +// rmqProducer contains a rocksmq producer type rmqProducer struct { p rocksmq.Producer }