rocket_mq

Documentation

Index

• type Producer
  • func NewProducer(opts ...producer.Option) (producer *Producer, err error)
  • func (p *Producer) Close() (err error)
  • func (p *Producer) Send(ctx context.Context, mq ...*primitive.Message) (result *primitive.SendResult, err error)
  • func (p *Producer) SendAsync(ctx context.Context, mq []*primitive.Message, ...) (err error)
  • func (p *Producer) SendOneWay(ctx context.Context, mq ...*primitive.Message) (err error)
  • func (p *Producer) Shutdown() (err error)
  • func (p *Producer) Start() (err error)
• type PushConsumer
  • func NewPushConsumer(opts ...consumer.Option) (pushConsumer *PushConsumer, err error)
  • func (pc *PushConsumer) Close() (err error)
  • func (pc *PushConsumer) Shutdown() (err error)
  • func (pc *PushConsumer) Start() (err error)
  • func (pc *PushConsumer) Subscribe(topic string, selector consumer.MessageSelector, ...) (err error)
  • func (pc *PushConsumer) Unsubscribe(topic string) (err error)

Types

type Producer

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

func NewProducer

func NewProducer(opts ...producer.Option) (producer *Producer, err error)

func (*Producer) Close

func (p *Producer) Close() (err error)

func (*Producer) Send

func (p *Producer) Send(ctx context.Context, mq ...*primitive.Message) (result *primitive.SendResult, err error)

func (*Producer) SendAsync

func (p *Producer) SendAsync(ctx context.Context, mq []*primitive.Message, callback func(ctx context.Context, result *primitive.SendResult, err error)) (err error)

func (*Producer) SendOneWay

func (p *Producer) SendOneWay(ctx context.Context, mq ...*primitive.Message) (err error)

func (*Producer) Shutdown

func (p *Producer) Shutdown() (err error)

func (*Producer) Start

func (p *Producer) Start() (err error)

type PushConsumer

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

func NewPushConsumer

func NewPushConsumer(opts ...consumer.Option) (pushConsumer *PushConsumer, err error)

func (*PushConsumer) Close

func (pc *PushConsumer) Close() (err error)

func (*PushConsumer) Shutdown

func (pc *PushConsumer) Shutdown() (err error)

func (*PushConsumer) Start

func (pc *PushConsumer) Start() (err error)

func (*PushConsumer) Subscribe

func (pc *PushConsumer) Subscribe(topic string, selector consumer.MessageSelector, handler func(ctx context.Context, ext ...*primitive.MessageExt) (consumer.ConsumeResult, error)) (err error)

func (*PushConsumer) Unsubscribe

func (pc *PushConsumer) Unsubscribe(topic string) (err error)