Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

rmqv2

package

Go to main page

Versions in this module

v1

v1.0.20

Apr 28, 2021

v1.0.19

Mar 31, 2021

v0

v0.0.1

May 25, 2021

Changes in this version

+ type Consumer struct

+ Consumer rocketmq.PushConsumer

+ func NewConsumer(conf *RocketMQConfig) (c *Consumer)

+ func (c *Consumer) Close()

+ func (c *Consumer) Conn() (conn *Consumer, err error)

+ func (c *Consumer) Start() (err error)

+ func (c *Consumer) SubscribeMulti(topic, expression string, ...) (err error)

+ func (c *Consumer) SubscribeSingle(topic, expression string, ...) (err error)

+ func (c *Consumer) TopicList() (ts []string)

+ func (c *Consumer) Unsubscribe(topic string) (err error)

+ type LogLevel string

+ const LogDebug

+ const LogError

+ const LogInfo

+ const LogWarn

+ type Producer struct

+ Producer rocketmq.Producer

+ func NewProducer(conf *RocketMQConfig) (p *Producer)

+ func (p *Producer) Close()

+ func (p *Producer) Conn() (conn *Producer, err error)

+ func (p *Producer) SendAsyncSingle(c context.Context, ...) (err error)

+ func (p *Producer) SendOneWaySingle(c context.Context, message *primitive.Message) (err error)

+ func (p *Producer) SendSyncSingle(c context.Context, message *primitive.Message) (result *primitive.SendResult, err error)

+ type RocketMQConfig struct

+ AccessKey string

+ ConsumerOptions []consumer.Option

+ EndPoint string

+ GroupName string

+ LogLevel LogLevel

+ Namespace string

+ ProducerOptions []producer.Option

+ SecretKey string