from: consumer to: primitive evidence: - file: "consumer/option.go" contains " "github.com/apache/rocketmq-client-go/v2/primitive"" from: consumer to: primitive evidence: - file: "consumer/offset_store.go" contains " "github.com/apache/rocketmq-client-go/v2/primitive"" from: consumer to: primitive evidence: - file: "consumer/push_consumer.go" contains " "github.com/apache/rocketmq-client-go/v2/primitive"" from: consumer to: primitive evidence: - file: "consumer/strategy.go" contains " "github.com/apache/rocketmq-client-go/v2/primitive"" from: consumer to: primitive evidence: - file: "consumer/message_util.go" contains " "github.com/apache/rocketmq-client-go/v2/primitive"" from: consumer to: primitive evidence: - file: "consumer/process_queue.go" contains " "github.com/apache/rocketmq-client-go/v2/primitive"" from: consumer to: primitive evidence: - file: "consumer/interceptor.go" contains " "github.com/apache/rocketmq-client-go/v2/primitive"" from: consumer to: primitive evidence: - file: "consumer/lock.go" contains " "github.com/apache/rocketmq-client-go/v2/primitive"" from: consumer to: primitive evidence: - file: "consumer/pull_consumer.go" contains " "github.com/apache/rocketmq-client-go/v2/primitive"" from: consumer to: primitive evidence: - file: "consumer/consumer.go" contains " "github.com/apache/rocketmq-client-go/v2/primitive"" from: consumer to: primitive evidence: - file: "consumer/statistics.go" contains " "github.com/apache/rocketmq-client-go/v2/primitive""