static synchronized void startHAServices(InternalCache cache) {
    if (qrmThread == null) {
      dispatchedMessagesMap = new ConcurrentHashMap<>();
      qrmThread = new QueueRemovalThread(cache);
      qrmThread.setName("Queue Removal Thread");
      qrmThread.start();
    }
  }
Creates the static dispatchedMessagesMap (if not present) and starts the QueuRemovalThread if
not running
geode-core/src/main/java/org/apache/geode/internal/cache/ha/HARegionQueue.java