Monitoring component:

        LOGGER.warning('[stop] end')

    def listen_events(self):

        LOGGER.warning('[listen_events] begin')

        try:

            kpi_id_list = []

            while not self._events_queue.empty():

                # LOGGER.info('getting Kpi by KpiID')

                LOGGER.warning('[listen_events] waiting event')

                event = self.get_event(block=True)

                LOGGER.warning('[listen_events] event received')

                if event.event.event_type == EventTypeEnum.EVENTTYPE_CREATE:

                    device = self._context_client.GetDevice(event.device_id)

                    for j,end_point in enumerate(device.device_endpoints):

                            kpi_id = self._monitoring_client.SetKpi(kpi_descriptor)

                            kpi_id_list.append(kpi_id)

            LOGGER.warning('[listen_events] return')

            return kpi_id_list

        except ServiceException as e:

            LOGGER.exception('ListenEvents exception')