sqs

package
v0.0.0-...-bb75541 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 11, 2016 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

View Source
const DefaultNumberOfMessages = 1

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

View Source
const DefaultWaitTimeSeconds = 20

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

Variables

View Source
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.

Types

This section is empty.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL