def METHOD_NAME(self, msg):
    self._event_queue.put(self._sentinel)
    with self._timestamp_lock:
        self._timeout_timestamp = datetime.datetime.now() + datetime.timedelta(
            seconds=self._reporter_timeout
        )
    if self._event_publisher_thread.is_alive():
        self._event_publisher_thread.join()