Events:

                    if self._log_events_received:

                        str_event = grpc_message_to_json_string(event)

                        LOGGER.info('[_collect] event: {:s}'.format(str_event))

                    object_name = str(event.__class__.__name__).lower().replace('event', '')

                    if object_name == 'any':

                        object_name = event.WhichOneof('event')

                        _event = getattr(event, object_name)

                        timestamp = _event.event.timestamp.timestamp

                    else:

                        timestamp = event.event.timestamp.timestamp

                    self._events_queue.put_nowait((timestamp, event))

            except grpc.RpcError as e: