def METHOD_NAME(self, broker: "Broker", message: "Message") -> None:
    limit = self.get_option("time_limit", broker=broker, message=message)
    deadline = time.monotonic() + limit / 1000
    with self.lock:
        self.deadlines[threading.get_ident()] = deadline, False, message