mq

Documentation

Index

• func NewMessage(topic string, data []byte) *primitive.Message
• type Consumer
  • func NewConsumer(cfg *ConsumerConfig) (Consumer, error)
• type ConsumerConfig
• type Producer
  • func NewProducer(cfg *ProducerConfig) (Producer, error)
• type ProducerConfig
• type SubscribeCallback
• type Subscriber

Functions

func NewMessage

func NewMessage(topic string, data []byte) *primitive.Message

Types

type Consumer

type Consumer interface {
	rocketmq.PushConsumer
}

Consumer defines mq push consumer

func NewConsumer

func NewConsumer(cfg *ConsumerConfig) (Consumer, error)

type ConsumerConfig

type ConsumerConfig struct {
	Addr        []string
	Subscriber  Subscriber
	Concurrence int
}

type Producer

type Producer interface {
	rocketmq.Producer
}

Producer defines mq message producer

func NewProducer

func NewProducer(cfg *ProducerConfig) (Producer, error)

type ProducerConfig

type ProducerConfig struct {
	Retry int
	Addr  []string
}

type SubscribeCallback

type SubscribeCallback func(context.Context, ...*primitive.MessageExt) (consumer.ConsumeResult, error)

type Subscriber

type Subscriber interface {
	Group() string
	Topic() string
	Consume(context.Context, ...*primitive.MessageExt) (consumer.ConsumeResult, error)
}