rocketmq

Documentation

Index

• func NewBroadCastConsumer(addr []string, consumerGroup string, consumerTopic string, ...) (mq.Consumer, error)
• func NewConsumer(addr []string, consumerGroup string, consumerTopic string, ...) (mq.Consumer, error)
• func NewProducer(addr []string, producerGroup string, selector producer.QueueSelector) (mq.Producer, error)
• func NewProducerWithRetry(addr []string, producerGroup string, retry int, ...) (mq.Producer, error)
• func NewRocketMQTransactionProducer(addr []string, producerGroup string, listener primitive.TransactionListener) (mq.TransactionProducer, error)
• func NewRocketMQTransactionProducerWithRetry(addr []string, producerGroup string, listener primitive.TransactionListener, ...) (mq.TransactionProducer, error)
• type RocketMQTransactionProducer
  • func (r *RocketMQTransactionProducer) MessageInTransaction(topic string, data []byte, shardingKeyValue *string) error
  • func (r *RocketMQTransactionProducer) ProducerStart(opts ...producer.Option) error
  • func (r *RocketMQTransactionProducer) ProducerStop() error
• type SubscribeHandler

Functions

func NewBroadCastConsumer

func NewBroadCastConsumer(addr []string, consumerGroup string, consumerTopic string, subscriber *SubscribeHandler) (mq.Consumer, error)

NewBroadCastConsumer 创建广播消息消费端

func NewConsumer

func NewConsumer(addr []string, consumerGroup string, consumerTopic string, subscriber *SubscribeHandler) (mq.Consumer, error)

NewConsumer 创建集群消息消费端

func NewProducer

func NewProducer(addr []string, producerGroup string, selector producer.QueueSelector) (mq.Producer, error)

func NewProducerWithRetry

func NewProducerWithRetry(addr []string, producerGroup string, retry int, selector producer.QueueSelector) (mq.Producer, error)

func NewRocketMQTransactionProducer

func NewRocketMQTransactionProducer(addr []string, producerGroup string, listener primitive.TransactionListener) (mq.TransactionProducer, error)

func NewRocketMQTransactionProducerWithRetry

func NewRocketMQTransactionProducerWithRetry(addr []string, producerGroup string, listener primitive.TransactionListener, retry int) (mq.TransactionProducer, error)

Types

type RocketMQTransactionProducer

type RocketMQTransactionProducer struct {
	// contains filtered or unexported fields
}

RocketMQTransactionProducer 基于rocket的事物消息的实现

func (*RocketMQTransactionProducer) MessageInTransaction

func (r *RocketMQTransactionProducer) MessageInTransaction(topic string, data []byte, shardingKeyValue *string) error

func (*RocketMQTransactionProducer) ProducerStart

func (r *RocketMQTransactionProducer) ProducerStart(opts ...producer.Option) error

func (*RocketMQTransactionProducer) ProducerStop

func (r *RocketMQTransactionProducer) ProducerStop() error

type SubscribeHandler

type SubscribeHandler struct {
	// 对 消息的属性进行条件过滤，例如标签、键值对 等
	Selector consumer.MessageSelector
	// 订阅完消息的回调函数
	Func func(context.Context, ...*primitive.MessageExt) (consumer.ConsumeResult, error)
}