@Override
  public int getDSFID() {
    return PR_QUERY_MESSAGE;
  }
Provide results to send back to requestor. terminate by returning END_OF_STREAM token object
geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/QueryMessage.java