public synchronized void synchronizeQueueWithPrimary(InternalDistributedMember primary,
      InternalCache cache) {
    if (scheduleSynchronizationWithPrimaryInProgress.get() || hasSynchronizedWithPrimary.get()
        || !doneGIIQueueing.get()) {
      // Order of the check is important here as timer scheduled thread
      // setting hasSynchronizedWithPrimary to true first before setting
      // scheduleSynchronizationWithPrimaryInProgress to false in doSynchronizationWithPrimary.
      return;
    }
    if (primary.getVersionOrdinal() < KnownVersion.GEODE_1_14_0.ordinal()) {
      if (logger.isDebugEnabled()) {
        logger.debug("Don't send to primary with version older than KnownVersion.GEODE_1_14_0");
      }
      return;
    }
    if (!hasSynchronizedWithPrimary.get() && !scheduleSynchronizationWithPrimaryInProgress.get()) {
      scheduleSynchronizationWithPrimaryInProgress.set(true);
    }
    long delay = getDelay();
    scheduleSynchronizationWithPrimary(primary, cache, delay);
  }
expiry time for ThreadIdentifiers. In seconds.
geode-core/src/main/java/org/apache/geode/internal/cache/ha/HARegionQueue.java