Versions in this module Expand all Collapse all v1 v1.0.20 Apr 28, 2021 v1.0.19 Mar 31, 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, message *primitive.Message) (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