sqsconsumer is a Go package to write workers that process messages from Amazon SQS
Switch branches/tags
Nothing to show
Clone or download
Fetching latest commit…
Cannot retrieve the latest commit at this time.
Permalink
Failed to load latest commit information.
cmd/sqsdrain
example
middleware
mock
router
sqsmessage
.gitignore
.travis.yml
LICENSE.txt
README.md
cleanup_delete.go
cleanup_delete_test.go
cleanup_visibility.go
cleanup_visibility_test.go
doc.go
gen_mocks.sh
message_handler.go
queue_consumer.go
queue_consumer_test.go
sqs_interface.go
sqs_interface_test.go
sqs_service.go
sqs_service_test.go

README.md

sqsconsumer

Build Status

sqsconsumer helps write programs that should respond to messages on an AWS SQS queue. Users of the package only write a processor implementation and then start a consumer bound to a specific queue and processor. The consumer will take care of extending message visibility if the processor takes a long time to run and of only deleting messages from the queue which were successfully processed. Context is passed into the processor so that complex/long workers can gracefully exit when the consumer is interrupted/killed.

See example/main.go for a simple demonstration.

TODO