Add Consumer Logic to update observe result for each connections