@Override
  public void process(final DistributionManager dm,
      final DLockRecoverGrantorProcessor.DLockRecoverGrantorMessage msg) {

    try {
      dm.getExecutors().getWaitingThreadPool().execute(
          () -> processDLockRecoverGrantorMessage(dm, msg));
    } catch (RejectedExecutionException e) {
      logger.debug("Rejected processing of {}", msg, e);
    }
  }
Provides processing of DLockRecoverGrantorProcessor. Reply will not be sent until all locks are
released.
geode-core/src/main/java/org/apache/geode/internal/cache/locks/TXRecoverGrantorMessageProcessor.java