Fixing consumer queuing behavior.
Implemented subscribe.
Stubs for `where` and `throttle`.