Closing gaps in consumer.

- Added connection callback bundle.
- Improved/formalized message handling.
- We now properly initialize connections new and reattempted.