to use take instead of the various message buffer objects. It will be easier to replace the actual component taking to SQS in tests and reduce the amount of boilerplate needed to keep various components operational.