@Test
  public void testDispatcher() throws Exception {
    clientPut(client1, KEY1, VALUE1);
    // Waiting in the client2 till it receives the event for the key.
    checkFromClient(client2);

    // performing check in the regionqueue of the server2
    checkFromServer(server2, KEY1);

    // For CQ Only.
    // performing put from the client1
    clientPut(client1, KEY2, VALUE2);
    checkFromClient(client2);
    checkFromServer(server2, KEY2);

    getLogWriter().info("testDispatcher() completed successfully");
  }
This Dunit test is to verify that when the dispatcher of CS dispatches the Event , the peer's
HARegionQueue should get the events removed from the HA RegionQueues assuming the QRM thread has
acted upon by that time This is done in the following steps 1. start server1 and server2 2. start
client1 and client2 3. perform put operation from client1 4. check the entry in the regionque of
client2 on server2.It should be present. 5. Wait till client2 receives event 6. Make sure that
QRM is envoked 7. Again the entry in the regionque of client2 on server2.It should not be
present. 8. close client1 and client2 9. close server1 and server2
geode-cq/src/distributedTest/java/org/apache/geode/internal/cache/ha/HADispatcherDistributedTest.java