def METHOD_NAME(self, callback, _filter, persistent_name=None):
    if persistent_name is not None:
        log.err(f'wampmq: persistent queues are not persisted: {persistent_name} {_filter}')
    qr = QueueRef(self, callback)
    self._startConsuming(qr, callback, _filter)
    return defer.succeed(qr)