Versions in this module Expand all Collapse all v0 v0.0.2 Feb 25, 2025 v0.0.1 Feb 25, 2025 Changes in this version + func NewConsumer(options []consumer.Option, topic string, ...) (rocketmq.PushConsumer, error) + func StartConsumer(nameServers []string, consumers []ConsumerConfig, ...) []rocketmq.PushConsumer + type ConsumerConfig struct + ConsumeFromWhere int + ConsumeMessageBatchMaxSize int + ConsumeTimeout int64 + GoroutineNums int + GroupName string + Handler string + InstanceName string + MessageSelector struct{ ... } + NameServers []string + PullBatchSize int + RetryNum int + Topic string + WorkerNum int + type MessageHandler func(ctx context.Context, msgs ...*primitive.MessageExt) (consumer.ConsumeResult, error) + type RocketMQX struct + ConsumerList []ConsumerConfig + NameServers []string
Go to main page