@VisibleForTesting
  Set<Long> getExtraPeekedIds() {
    return Collections.unmodifiableSet(extraPeekedIds);
  }
shutdown this thread and the caller thread will join this thread
geode-core/src/main/java/org/apache/geode/internal/cache/wan/serial/SerialGatewaySenderQueue.java