def notify_query(method_name, collection, query, *args)
      query_obj = Persistors::ArrayStore.query_pool.lookup(collection, query)
      query_obj.send(method_name, *args)
    end
def notify_query(method_name, collection, query, *args)
      query_obj = Persistors::ArrayStore.query_pool.lookup(collection, query)
      query_obj.send(method_name, *args)
    end
Called when the backend sends a notification to change the results of
 a query.