rocketmq

Documentation

Index

• type RocketMQPushConsumer
  • func NewRocketMQPushConsumer(conf con.Conf) (*RocketMQPushConsumer, error)
  • func (c *RocketMQPushConsumer) Shutdown() error
  • func (c *RocketMQPushConsumer) Start() error
  • func (c *RocketMQPushConsumer) Subscribe(topic string, ...) error

Types

type RocketMQPushConsumer

type RocketMQPushConsumer struct {
	Conf     con.Conf
	Consumer rocketmq.PushConsumer
}

func NewRocketMQPushConsumer

func NewRocketMQPushConsumer(conf con.Conf) (*RocketMQPushConsumer, error)

func (*RocketMQPushConsumer) Shutdown

func (c *RocketMQPushConsumer) Shutdown() error

func (*RocketMQPushConsumer) Start

func (c *RocketMQPushConsumer) Start() error

func (*RocketMQPushConsumer) Subscribe

func (c *RocketMQPushConsumer) Subscribe(topic string, callback func(ctx context.Context, msgs ...*mq.MessageExt) (int, error)) error