rocketmq

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

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

type Metadata struct {
	// sdk proto (http or tcp),default tcp
	AccessProto string `json:"accessProto,omitempty"`

	// rocketmq Credentials
	AccessKey string `json:"accessKey,omitempty"`

	// rocketmq Credentials
	SecretKey string `json:"secretKey,omitempty"`

	// rocketmq's endpoint, optional, just for http proto
	Endpoint string `json:"endpoint,omitempty"`

	// rocketmq's name server, optional
	NameServer string `json:"nameServer,omitempty"`

	// rocketmq's namespace, optional
	InstanceId string `json:"instanceId,omitempty"`

	// consumer group for rocketmq's subscribers, suggested to provide
	ConsumerGroup string `json:"consumerGroup,omitempty"`

	// consumer group for rocketmq's subscribers, suggested to provide, just for http proto
	ConsumerBatchSize int `json:"consumerBatchSize,string,omitempty"`

	// consumer group for rocketmq's subscribers, suggested to provide, just for cgo proto
	ConsumerThreadNums int `json:"consumerThreadNums,string,omitempty"`

	// rocketmq's name server domain, optional
	NameServerDomain string `json:"nameServerDomain,omitempty"`

	// retry times to connect rocketmq's broker, optional
	Retries int `json:"retries,string,omitempty"`
}

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

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

type Producer interface {
	Init(md *Metadata) error
	Start() error
	Shutdown() error
	SendSync(ctx context.Context, mq ...*primitive.Message) (*primitive.SendResult, error)
	SendAsync(ctx context.Context, mq func(ctx context.Context, result *primitive.SendResult, err error),
		msg ...*primitive.Message) error
	SendOneWay(ctx context.Context, mq ...*primitive.Message) error
}

type PushConsumer interface {
	Init(md *Metadata) error

	// Start the PullConsumer for consuming message
	Start() error

	// Shutdown the PullConsumer, all offset of MessageQueue will be sync to broker before process exit
	Shutdown() error

	// Subscribe a topic for consuming
	Subscribe(topic string, selector consumer.MessageSelector, f func(context.Context, ...*primitive.MessageExt) (mqc.ConsumeResult, error)) error

	// Unsubscribe a topic
	Unsubscribe(topic string) error
}