private void waitForEventsRemovedByQueueRemovalMessage(VM secondaryServerVM,
      final String durableClientId) {
    secondaryServerVM.invoke(() -> DurableClientSimpleDUnitTest
        .waitForEventsRemovedByQueueRemovalMessage(durableClientId));
  }
Test that starting a durable client on multiple servers is processed correctly.
geode-cq/src/distributedTest/java/org/apache/geode/internal/cache/tier/sockets/DurableClientSimpleDUnitTest.java