consumer

Mar 11, 2024

Changes in this version

type Consumer

+ func (this *Consumer) NewCustomConsumer(c *rocketmq.PushConsumer)

Dec 18, 2023

Changes in this version

+ type Consumer struct

+ func New() *Consumer

+ func (this *Consumer) NewConsumer(server, groupName string) error

+ func (this *Consumer) Shutdown() error

+ func (this *Consumer) Start() error

+ func (this *Consumer) Subscribe(topic string, _receiver OnReceiver) error

+ type OnReceiver func(msg *primitive.MessageExt)