def METHOD_NAME(self, routingKey, msg):
    if self.verifyMessages:
        validation.verifyMessage(self.testcase, routingKey, msg)
    matched = False
    for q in self.qrefs:
        if tuplematch.matchTuple(routingKey, q.filter):
            matched = True
            self._deferwaiter.add(q.callback(routingKey, msg))
    if not matched:
        raise AssertionError("no consumer found")