@VisibleForTesting
  long getLastPeekedId() {
    return lastPeekedId.get();
  }
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