def connect(self, core_management_host, core_management_port):
        svc = self._get_storage_service(host=core_management_host, port=core_management_port)
        if len(svc) == 0:
            raise InvalidServiceInstance
        self.service = ServiceRecord(s_id=svc["id"], s_name=svc["name"], s_type=svc["type"], s_port=svc["service_port"],
                                     m_port=svc["management_port"], s_address=svc["address"],
                                     s_protocol=svc["protocol"])

        return self