consumer

Documentation

Index

• func NewConsumerWorkers(loader conf.IConfigLoader, handler application.IAnnotationQueueConsumer) ([]mq.IConsumerWorker, error)
• type AnnotationConsumer
  • func (e *AnnotationConsumer) ConsumerCfg(ctx context.Context) (*mq.ConsumerConfig, error)
  • func (e *AnnotationConsumer) HandleMessage(ctx context.Context, ext *mq.MessageExt) error

Functions

func NewConsumerWorkers

func NewConsumerWorkers(
	loader conf.IConfigLoader,
	handler application.IAnnotationQueueConsumer,
) ([]mq.IConsumerWorker, error)

Types

type AnnotationConsumer

type AnnotationConsumer struct {
	conf.IConfigLoader
	// contains filtered or unexported fields
}

func (*AnnotationConsumer) ConsumerCfg

func (e *AnnotationConsumer) ConsumerCfg(ctx context.Context) (*mq.ConsumerConfig, error)

func (*AnnotationConsumer) HandleMessage

func (e *AnnotationConsumer) HandleMessage(ctx context.Context, ext *mq.MessageExt) error