mq

Documentation

Index

• type RocketMQ
  • func NewRocketMQ(cons_opts []consumer.Option, prod_opts []producer.Option, reply bool) *RocketMQ
  • func (this *RocketMQ) Init()
  • func (this *RocketMQ) SendAsync(topic, json string, ...) error
  • func (this *RocketMQ) SendSync(topic, json string) (*primitive.SendResult, error)
  • func (this *RocketMQ) Shutdown()
  • func (this *RocketMQ) Start()
  • func (this *RocketMQ) Subscribe(topic string, _receiver cons.OnReceiver)
  • func (this *RocketMQ) Wait(ctx context.Context)

Types

type RocketMQ

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

func NewRocketMQ

func NewRocketMQ(cons_opts []consumer.Option, prod_opts []producer.Option, reply bool) *RocketMQ

func (*RocketMQ) Init

func (this *RocketMQ) Init()

func (*RocketMQ) SendAsync

func (this *RocketMQ) SendAsync(topic, json string, mq func(ctx context.Context, result *primitive.SendResult, err error)) error

func (*RocketMQ) SendSync

func (this *RocketMQ) SendSync(topic, json string) (*primitive.SendResult, error)

func (*RocketMQ) Shutdown

func (this *RocketMQ) Shutdown()

func (*RocketMQ) Start

func (this *RocketMQ) Start()

func (*RocketMQ) Subscribe

func (this *RocketMQ) Subscribe(topic string, _receiver cons.OnReceiver)

func (*RocketMQ) Wait

func (this *RocketMQ) Wait(ctx context.Context)