diff --git a/internal/util/mqclient/rmq_reader.go b/internal/util/mqclient/rmq_reader.go index eb4859535c..148678584d 100644 --- a/internal/util/mqclient/rmq_reader.go +++ b/internal/util/mqclient/rmq_reader.go @@ -8,6 +8,7 @@ import ( var _ Reader = (*rmqReader)(nil) +// rmqReader contains a rocksmq reader type rmqReader struct { r rocksmq.Reader }