Added duplex communication with client and db observer