consumer

Documentation

Index

• type MessageConsumer
• type MessageHandler
  • func DecorateConsumeFn(f func(*sqs.Message) error) MessageHandler
  • func (mh MessageHandler) Consume(c <-chan *sqs.Message, wg *sync.WaitGroup)

Types

type MessageConsumer

type MessageConsumer interface {
	Consume(<-chan *sqs.Message, *sync.WaitGroup)
}

MessageConsumer is an interface defining operations that a basic SQS message consumer should implement.

type MessageHandler

type MessageHandler func(<-chan *sqs.Message, *sync.WaitGroup)

MessageHandler is a handy type to make a function a message consumer.

func DecorateConsumeFn

func DecorateConsumeFn(f func(*sqs.Message) error) MessageHandler

DecorateConsumeFn is a decorator for consumer function.

It handles the WaitGroup, receives message from the input channel. The consumer just focuses on the task of consuming a SQS message. To delete a message or not, it fully depends on the consumer itself.

func (MessageHandler) Consume

func (mh MessageHandler) Consume(c <-chan *sqs.Message, wg *sync.WaitGroup)

Consume implements the MessageConsumer interface.