@Test
  public void testClientOnAccessorReceivesCqEvents() throws Exception {
    Object[] args1 = new Object[] {REGION_NAME, 1, 0, 8, false, null};
    Object[] args2 = new Object[] {REGION_NAME, 1, 50, 8, false, null};

    dataStore2.invoke(() -> createCacheServerWithPR(REGION_NAME, 1, 50, 8, false, null));
    int port1 = dataStore1.invoke(() -> createCacheServerWithPR(REGION_NAME, 1, 0, 8, false, null));

    // both clients are attached to accessor
    createClientCache(port1, false, true, false);
    // no register interest but register cq
    client1.invoke(() -> createClientCache(port1, false, false, true));

    // feed delta
    // This delta obj satisfies CQ
    DeltaTestImpl test = new DeltaTestImpl(8, "");
    deltaPR.put(DELTA_KEY, test);

    // newValue does not satisfy CQ while oldValue does
    test.setIntVar(10);
    deltaPR.put(DELTA_KEY, test);

    deltaPR.put(LAST_KEY, new DeltaTestImpl(8, ""));

    client1.invoke(this::waitForLastKey);
    boolean flag = client1.invoke(this::verifyQueryUpdateExecuted);
    assertTrue("client update cq not executed properly", flag);
    flag = client1.invoke(this::verifyQueryDestroyExecuted);
    assertTrue("client destroy cq not executed properly", flag);
  }
Topology: PR: Accessor, dataStore. client and client1 connected to PR accessor; client puts
delta objects on dataStore via accessor Accessor gets adjunctMessage about put Verify on
client1 that queryUpdate and queryDestroy are executed properly
geode-cq/src/distributedTest/java/org/apache/geode/internal/cache/PRDeltaPropagationDistributedTest.java