def METHOD_NAME(self, message_type, message):
    self._queue_backlog(message_type, message)
    active_engine = self._consensus_registry.get_active_engine_info()
    if active_engine is not None:
        for (queued_type, queued_msg) in self._drain_backlog():
            try:
                self._service.send(
                    queued_type,
                    bytes(queued_msg),
                    active_engine.connection_id
                ).result(timeout=NOTIFICATION_TIMEOUT)
            except FutureTimeoutError:
                LOGGER.warning(
                    "Consensus notification %s timed out",
                    get_enum_name(queued_type))