implemented async messages processing