Implemented ConsumerCallbacks.

- The consumer can now take a ConsumerCallbacks object rather than forcing ConnectionCallbacks for our purposes.
- We now implement the RDY reset as "rdy_replenish" on the consumer-callbacks. It can be overwritten if automation is not required.