@Override
  public CqListener[] getCqListeners() {
    final ArrayList listeners = cqListeners;
    if (listeners == null) {
      return CqAttributesImpl.EMPTY_LISTENERS;
    }

    CqListener[] result = null;
    synchronized (clSync) {
      result = new CqListener[listeners.size()];
      listeners.toArray(result);
    }
    return result;

  }
Returns the CqListeners set with the CQ

@return CqListener[]
geode-core/src/main/java/org/apache/geode/cache/query/internal/cq/CqAttributesImpl.java