sqs

Documentation

Index

• Constants
• Variables
• func Start(output chan<- *awsSqs.Message) error
• func Stop() error

Constants

const DefaultNumberOfMessages = 1

DefaultNumberOfMessages is the default value for max number of messages to return.

const DefaultWaitTimeSeconds = 20

DefaultWaitTimeSeconds is the default value for duration for which the call will wait for a message to arrive.

Variables

var DeleteMessage = func(message *awsSqs.Message) (err error) {
	_, err = service.DeleteMessage(
		&awsSqs.DeleteMessageInput{
			QueueUrl:      &queueURL,
			ReceiptHandle: message.ReceiptHandle,
		},
	)
	return
}

DeleteMessage deletes a sqs.Message

Functions

func Start

func Start(output chan<- *awsSqs.Message) error

Start makes it start to poll SQS.

func Stop

func Stop() error

Stop stops polling SQS.