@Test
  public void parallelAsyncEventQueueAssociationToReplicateRegionTroughAttributesMutatorShouldFail() {
    Integer lnPort = vm0.invoke(() -> createFirstLocatorWithDSId(1));

    createCacheInVMs(lnPort, vm1);
    String regionName = getTestMethodName() + "_RR";
    String asyncEventQueueId = getTestMethodName() + "_asyncEventQueue";
    vm1.invoke(() -> {
      createReplicatedRegion(regionName, null, isOffHeap());
      createAsyncEventQueue(asyncEventQueueId, true, 100, 100, false, false, null, false);

      assertThatThrownBy(
          () -> addAsyncEventQueueThroughAttributesMutator(regionName, asyncEventQueueId))
              .isInstanceOf(AsyncEventQueueConfigurationException.class)
              .hasMessage("Parallel Async Event Queue " + asyncEventQueueId
                  + " can not be used with replicated region " + SEPARATOR + 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