cloudant/rexi — pull request #4 by kocolosk (2012-07-16 21:23:05+00:00)
Title: 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.

We hope to use this code in a new implementation of clustered view coordination in fabric. We're getting the worker side of the protocol deployed now buy delaying the coordinator side to avoid any failed requests during the final upgrade.

BugzID: 13311