Added duplex communication with client and database observer