queue

Jun 10, 2022

Changes in this version

+ type Config struct

+ Enabled bool

+ Endpoint string

+ QueueArn string

+ QueueName string

+ Timeout int64

+ WaitTime int64

+ type MessageProcessor func(context.Context, []byte) error

+ type SQSConsumer struct

+ func NewConsumer(c Config, log log.Logger, processor MessageProcessor) (*SQSConsumer, error)

+ func (s *SQSConsumer) ProcessMessages(ctx context.Context)