Refactor connection to conform with the new architecture
Refactor connection to conform with the new architecture

deepakshinde/beaneater,beanstalkd/beaneater,krautcomputing/beaneater,bfolkens/beaneater