tree 978db9ead38eb08120072a1fb1412d692fb2df4d
parent c6b77781da5cf48917c3bb45901176d56725194f
author Paul J. Davis <paul.joseph.davis@gmail.com> 1339543741 -0500
committer Paul J. Davis <paul.joseph.davis@gmail.com> 1339704673 -0500

Implement message stream interface

This allows workers to stream messages to a coordinator process which is
then responsible for acking each message. When a worker reaches a
configurable number of outstanding messages it will wait for acks before
continuing to send messages.