@Override
                public void afterInvalidate(EntryEvent event) {
                  try {
                    expireTheEventOrThreadIdentifier(event);
                  } catch (CacheException ce) {
                    logger.error(
                        "HAREgionQueue::createCacheListener::Exception in the expiry thread", ce);
                  }
                  if (event.getKey() instanceof ThreadIdentifier) {
                    synchronized (HARQAddOperationJUnitTest.this) {
                      expiryCount++;
                      HARQAddOperationJUnitTest.this.notify();
                    }
                  }
                }
Add with QRM & expiry : Add 10 conflatable objects (0-9). Send QRM LastDispatched as 4.
Validate the sequence ID field of LastDispatchedWrapper object is updated to 4. Perform Take
operations to remove next 5 to 9. The seqeunceId field should be 9. Allow ThreadIdenitifier to
expire. The expiration should fail as the original sequenceId ( -1) does not match with 9.
Validate reset with value 9 . The next expiry should remove the LastDisptachedWrapper
geode-core/src/integrationTest/java/org/apache/geode/internal/cache/ha/HARQAddOperationJUnitTest.java