consumer

Documentation

Index

• type PushConsumer
  • func NewPushConsumer(opts ...*PushConsumerOption) (*PushConsumer, error)
• type PushConsumerOption
  • func ConfigPushConsumerOption(key string) (option *PushConsumerOption, err error)
  • func NewPushConsumerOption() *PushConsumerOption
  • func PushConsumerAddInterceptor(f ...primitive.Interceptor) *PushConsumerOption
  • func PushConsumerSetAccessKey(l string) *PushConsumerOption
  • func PushConsumerSetAllocateStrategy(a consumer.AllocateStrategy) *PushConsumerOption
  • func PushConsumerSetAutoCommit(l bool) *PushConsumerOption
  • func PushConsumerSetConsumeFromWhere(l string) *PushConsumerOption
  • func PushConsumerSetConsumeMessageBatchMaxSize(l int) *PushConsumerOption
  • func PushConsumerSetConsumeOrderly(l bool) *PushConsumerOption
  • func PushConsumerSetConsumerModel(l string) *PushConsumerOption
  • func PushConsumerSetGroupName(l string) *PushConsumerOption
  • func PushConsumerSetInstanceName(l string) *PushConsumerOption
  • func PushConsumerSetLogLevel(l string) *PushConsumerOption
  • func PushConsumerSetLogger(l baselogger.RocketmqLogger) *PushConsumerOption
  • func PushConsumerSetNameServer(l string) *PushConsumerOption
  • func PushConsumerSetNamespace(l string) *PushConsumerOption
  • func PushConsumerSetPullBatchSize(l int) *PushConsumerOption
  • func PushConsumerSetRetryTimes(l int) *PushConsumerOption
  • func PushConsumerSetSecretKey(l string) *PushConsumerOption
  • func (c *PushConsumerOption) AddInterceptor(f ...primitive.Interceptor) *PushConsumerOption
  • func (c *PushConsumerOption) MergeOption(opts ...*PushConsumerOption) *PushConsumerOption
  • func (c *PushConsumerOption) PushConsumerSetLogLevel(l string) *PushConsumerOption
  • func (c *PushConsumerOption) SetAccessKey(l string) *PushConsumerOption
  • func (c *PushConsumerOption) SetAllocateStrategy(a consumer.AllocateStrategy) *PushConsumerOption
  • func (c *PushConsumerOption) SetAutoCommit(l bool) *PushConsumerOption
  • func (c *PushConsumerOption) SetConsumeFromWhere(l string) *PushConsumerOption
  • func (c *PushConsumerOption) SetConsumeMessageBatchMaxSize(l int) *PushConsumerOption
  • func (c *PushConsumerOption) SetConsumeOrderly(l bool) *PushConsumerOption
  • func (c *PushConsumerOption) SetConsumerModel(l string) *PushConsumerOption
  • func (c *PushConsumerOption) SetGroupName(l string) *PushConsumerOption
  • func (c *PushConsumerOption) SetInstanceName(l string) *PushConsumerOption
  • func (c *PushConsumerOption) SetLogger(l baselogger.RocketmqLogger) *PushConsumerOption
  • func (c *PushConsumerOption) SetNameServer(l string) *PushConsumerOption
  • func (c *PushConsumerOption) SetNamespace(l string) *PushConsumerOption
  • func (c *PushConsumerOption) SetPullBatchSize(l int) *PushConsumerOption
  • func (c *PushConsumerOption) SetRetryTimes(l int) *PushConsumerOption
  • func (c *PushConsumerOption) SetSecretKey(l string) *PushConsumerOption

Types

type PushConsumer

type PushConsumer struct {
	rocketmq.PushConsumer
	Logger baselogger.RocketmqLogger
}

func NewPushConsumer

func NewPushConsumer(opts ...*PushConsumerOption) (*PushConsumer, error)

type PushConsumerOption

type PushConsumerOption struct {
	GroupName    string
	InstanceName string // 访问多个rocketmq集群才需要设置
	NameServer   string // TCP接入点
	AccessKey    string
	SecretKey    string
	Namespace    string
	// 	BroadCasting
	// 	Clustering
	ConsumerModel string
	// 	lastoffset
	// 	firstoffset
	// 	timestamp
	ConsumeFromWhere           string
	ConsumeOrderly             bool
	ConsumeMessageBatchMaxSize int
	PullBatchSize              int
	AllocateStrategy           consumer.AllocateStrategy
	RetryTimes                 int
	Interceptors               []primitive.Interceptor
	AutoCommit                 bool
	Logger                     baselogger.RocketmqLogger
	LogLevel                   string
}

func ConfigPushConsumerOption

func ConfigPushConsumerOption(key string) (option *PushConsumerOption, err error)

RawConfig ...

func NewPushConsumerOption

func NewPushConsumerOption() *PushConsumerOption

func PushConsumerAddInterceptor

func PushConsumerAddInterceptor(f ...primitive.Interceptor) *PushConsumerOption

func PushConsumerSetAccessKey

func PushConsumerSetAccessKey(l string) *PushConsumerOption

func PushConsumerSetAllocateStrategy

func PushConsumerSetAllocateStrategy(a consumer.AllocateStrategy) *PushConsumerOption

func PushConsumerSetAutoCommit

func PushConsumerSetAutoCommit(l bool) *PushConsumerOption

func PushConsumerSetConsumeFromWhere

func PushConsumerSetConsumeFromWhere(l string) *PushConsumerOption

func PushConsumerSetConsumeMessageBatchMaxSize

func PushConsumerSetConsumeMessageBatchMaxSize(l int) *PushConsumerOption

func PushConsumerSetConsumeOrderly

func PushConsumerSetConsumeOrderly(l bool) *PushConsumerOption

func PushConsumerSetConsumerModel

func PushConsumerSetConsumerModel(l string) *PushConsumerOption

func PushConsumerSetGroupName

func PushConsumerSetGroupName(l string) *PushConsumerOption

func PushConsumerSetInstanceName

func PushConsumerSetInstanceName(l string) *PushConsumerOption

func PushConsumerSetLogLevel

func PushConsumerSetLogLevel(l string) *PushConsumerOption

func PushConsumerSetLogger

func PushConsumerSetLogger(l baselogger.RocketmqLogger) *PushConsumerOption

func PushConsumerSetNameServer

func PushConsumerSetNameServer(l string) *PushConsumerOption

func PushConsumerSetNamespace

func PushConsumerSetNamespace(l string) *PushConsumerOption

func PushConsumerSetPullBatchSize

func PushConsumerSetPullBatchSize(l int) *PushConsumerOption

func PushConsumerSetRetryTimes

func PushConsumerSetRetryTimes(l int) *PushConsumerOption

func PushConsumerSetSecretKey

func PushConsumerSetSecretKey(l string) *PushConsumerOption

func (*PushConsumerOption) AddInterceptor

func (c *PushConsumerOption) AddInterceptor(f ...primitive.Interceptor) *PushConsumerOption

func (*PushConsumerOption) MergeOption

func (c *PushConsumerOption) MergeOption(opts ...*PushConsumerOption) *PushConsumerOption

func (*PushConsumerOption) PushConsumerSetLogLevel

func (c *PushConsumerOption) PushConsumerSetLogLevel(l string) *PushConsumerOption

func (*PushConsumerOption) SetAccessKey

func (c *PushConsumerOption) SetAccessKey(l string) *PushConsumerOption

func (*PushConsumerOption) SetAllocateStrategy

func (c *PushConsumerOption) SetAllocateStrategy(a consumer.AllocateStrategy) *PushConsumerOption

func (*PushConsumerOption) SetAutoCommit

func (c *PushConsumerOption) SetAutoCommit(l bool) *PushConsumerOption

func (*PushConsumerOption) SetConsumeFromWhere

func (c *PushConsumerOption) SetConsumeFromWhere(l string) *PushConsumerOption

func (*PushConsumerOption) SetConsumeMessageBatchMaxSize

func (c *PushConsumerOption) SetConsumeMessageBatchMaxSize(l int) *PushConsumerOption

func (*PushConsumerOption) SetConsumeOrderly

func (c *PushConsumerOption) SetConsumeOrderly(l bool) *PushConsumerOption

func (*PushConsumerOption) SetConsumerModel

func (c *PushConsumerOption) SetConsumerModel(l string) *PushConsumerOption

func (*PushConsumerOption) SetGroupName

func (c *PushConsumerOption) SetGroupName(l string) *PushConsumerOption

func (*PushConsumerOption) SetInstanceName

func (c *PushConsumerOption) SetInstanceName(l string) *PushConsumerOption

func (*PushConsumerOption) SetLogger

func (c *PushConsumerOption) SetLogger(l baselogger.RocketmqLogger) *PushConsumerOption

func (*PushConsumerOption) SetNameServer

func (c *PushConsumerOption) SetNameServer(l string) *PushConsumerOption

func (*PushConsumerOption) SetNamespace

func (c *PushConsumerOption) SetNamespace(l string) *PushConsumerOption

func (*PushConsumerOption) SetPullBatchSize

func (c *PushConsumerOption) SetPullBatchSize(l int) *PushConsumerOption

func (*PushConsumerOption) SetRetryTimes

func (c *PushConsumerOption) SetRetryTimes(l int) *PushConsumerOption

func (*PushConsumerOption) SetSecretKey

func (c *PushConsumerOption) SetSecretKey(l string) *PushConsumerOption