@Test
  public void warningShouldBeLoggedWhenSerialAsyncEventQueueIsNotConfiguredAcrossAllMembersHostingTheReplicateRegionTroughAttributesMutator() {
    Integer lnPort = vm0.invoke(() -> createFirstLocatorWithDSId(1));
    createCacheInVMs(lnPort, vm4, vm5, vm6, vm7);

    asList(vm4, vm5, vm6, vm7).forEach(vm -> vm.invoke(() -> {
      createAsyncEventQueue("ln", false, 100, 100, false, false, null, false);
      createReplicatedRegion(getTestMethodName() + "_RR", null, isOffHeap());
    }));

    String regionName = getTestMethodName() + "_RR";
    asList(vm4, vm5).forEach(vm -> vm.invoke(() -> {
      addAsyncEventQueueThroughAttributesMutator(regionName, "ln");
    }));

    verifyNoAsyncEventQueueIdWarning(regionName);
    vm4.invoke(() -> doPuts(regionName, 1000));
    verifyAsyncEventQueueIdWarning(regionName);

    asList(vm6, vm7).forEach(vm -> vm.invoke(() -> {
      addAsyncEventQueueThroughAttributesMutator(regionName, "ln");
    }));

    vm4.invoke(() -> doPuts(regionName, 1000));
    verifyNoAsyncEventQueueIdWarning(regionName);
  }
Two VMs are part of the DS. One VM hosts a cache server while the other hosts a Receiver.
Expected: Cache.getCacheServers should only return the bridge server and not the Receiver.
geode-wan/src/distributedTest/java/org/apache/geode/internal/cache/wan/misc/WanValidationsDUnitTest.java