rocketmq

README

RocketMQ

Broker: RocketMQ

You can run examples by replace configs use your rocketmq instance configs.

Typically log msg in interceptors, default provide producer and push consumer inteceptor.

Documentation

Index

• func SetLogLevel(level string)
• type ConsumerConfig
• type Interceptor
• type Message
• type MessageExt
• type Producer
  • func NewProducer(config *ProducerConfig) *Producer
  • func (p *Producer) SendAsyncMsg(ctx context.Context, content string, ...) error
  • func (p *Producer) SendSyncMsg(ctx context.Context, content string, tags ...string) error
  • func (p *Producer) Shutdown() error
  • func (p *Producer) Start() error
• type ProducerConfig
• type PushConsumer
  • func NewPushConsumer(config *ConsumerConfig) *PushConsumer
  • func (pc *PushConsumer) Shutdown() error
  • func (pc *PushConsumer) Start() error
  • func (pc *PushConsumer) Subscribe(cb func(context.Context, *primitive.MessageExt) error) *PushConsumer

Functions

func SetLogLevel

func SetLogLevel(level string)

SetLogLevel set rocket mq log level

Types

type ConsumerConfig

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

	Topic string
	Gid   string
	Tags  []string
	Retry int32

	Orderly bool
	// contains filtered or unexported fields
}

ConsumerConfig RocketMQ consumer config

type Interceptor

type Interceptor = primitive.Interceptor

Interceptor is an alias of primitive.Interceptor

type Message

type Message = primitive.Message

Message is an alias of primitive.Message

type MessageExt

type MessageExt = primitive.MessageExt

MessageExt is an alias of primitive.MessageExt

type Producer

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

Producer producer config

func NewProducer

func NewProducer(config *ProducerConfig) *Producer

NewProducer returns a Producer instance

func (*Producer) SendAsyncMsg

func (p *Producer) SendAsyncMsg(ctx context.Context, content string, callback func(context.Context, *primitive.SendResult, error), tags ...string) error

SendAsyncMsg send message async

func (*Producer) SendSyncMsg

func (p *Producer) SendSyncMsg(ctx context.Context, content string, tags ...string) error

SendSyncMsg send message sync

func (*Producer) Shutdown

func (p *Producer) Shutdown() error

Shutdown producer

func (*Producer) Start

func (p *Producer) Start() error

Start start producer

type ProducerConfig

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
}

ProducerConfig RocketMQ producer config

type PushConsumer

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

PushConsumer push consumer mode

func NewPushConsumer

func NewPushConsumer(config *ConsumerConfig) *PushConsumer

NewPushConsumer returns a PushConsumer instance

func (*PushConsumer) Shutdown

func (pc *PushConsumer) Shutdown() error

Shutdown consumer

func (*PushConsumer) Start

func (pc *PushConsumer) Start() error

Start start consumer

func (*PushConsumer) Subscribe

func (pc *PushConsumer) Subscribe(cb func(context.Context, *primitive.MessageExt) error) *PushConsumer

Subscribe subscribe topic