Added more stuff like connection abstraction and PubSub listeners.