def METHOD_NAME(self, **query):
    def decorator(func):
        decorated = callinfo.acallqueue(func)
        self._subscribers.append((query, decorated))
        return decorated
    return decorator