rocketmq

type ConsumerConfig struct {
	Endpoint  []string
	AccessKey string
	SecretKey string

	Topic string
	Gid   string
	Tags  []string
	Retry int32

	Orderly bool
	// contains filtered or unexported fields
}

type Interceptor = primitive.Interceptor

type Message = primitive.Message

type MessageExt = primitive.MessageExt

type Producer struct {
	// contains filtered or unexported fields
}

type ProducerConfig struct {
	Endpoint  []string
	AccessKey string
	SecretKey string

	Retry       int
	SendTimeout time.Duration

	Topic string
	Gid   string

	SlowSendDuration time.Duration
	// contains filtered or unexported fields
}

type PushConsumer struct {
	// contains filtered or unexported fields
}