Added initial support for in-process consumers. Rough riding.