@Override
    public void init(Properties props) {}
This is the client listener which notifies the waiting thread when it receives the event.
geode-cq/src/distributedTest/java/org/apache/geode/internal/cache/ha/HADispatcherDistributedTest.java