Update client.py to add consumer in the API.

[hemna]

This adds a layer between the client object and the actual client instance, so we can reset the actual client object instance upon failure of connection.