@Override
  public void resumeCQ(int cqState, ServerCQ cQuery) {
    // Initialize the state of CQ.
    if (((CqStateImpl) cQuery.getState()).getState() != cqState) {
      cQuery.setCqState(cqState);
      // addToCqEventKeysMap(cQuery);
      // Send state change info to peers.
      cQuery.getCqBaseRegion().getFilterProfile().setCqState(cQuery);
    }
    // If we are going to set the state to running, we need to check to see if it matches any other
    // cq
    if (cqState == CqStateImpl.RUNNING) {
      // Add to the matchedCqMap.
      addToMatchingCqMap((CqQueryImpl) cQuery);
    }
  }
Executes the given CqQuery, if the CqQuery for that name is not there it registers the one and
executes. This is called on the Server.

@param manageEmptyRegions whether to update the 6.1 emptyRegions map held in the CCN
@param regionDataPolicy the data policy of the region associated with the query. This is only
       needed if manageEmptyRegions is true.
@param emptyRegionsMap map of empty regions.
@throws IllegalStateException if this is called at client side.
geode-cq/src/main/java/org/apache/geode/cache/query/cq/internal/CqServiceImpl.java