A framework for processing data on SNS+SQS and/or Kinesis streams.

 See the README.md file in qs-core/src/main/java/com/blacklocus/qs/drivers/ for an overview and examples.
Yes, I like that (MessageWriter). @megallo has written something very similar (MessageService and CoreMessageService) in her maybe-match PR:

https://github.com/blacklocus/blacklocus/pull/1782#issuecomment-65659989

I'd love to merge her work into here. Her CoreMessageService (I'd call it an SQSMessageWriter), is a much better implementation than QueueWriter. It handles retries, for example.