rocketmq

Imports

• github.com/aliyunmq/mq-http-go-sdk
• github.com/apache/rocketmq-client-go/v2/consumer
• github.com/apache/rocketmq-client-go/v2/primitive
• github.com/apache/rocketmq-client-go/v2/producer
• github.com/go-kratos/kratos/v2/log
• github.com/gogap/errors
• go.opentelemetry.io/otel/attribute
• go.opentelemetry.io/otel/propagation
• go.opentelemetry.io/otel/semconv/v1.12.0
• go.opentelemetry.io/otel/trace

Standard library imports

• context
• errors
• strings
• sync
• time
• user-job/pkg/broker
• user-job/pkg/tracing
• user-rpc-rpc-api-user-rpc-job/pkg/broker