@Category({WanTest.class})
  @Test
  public void testSenderMBean() throws Exception {

    VM nyLocator = getManagedNodeList().get(0);
    VM nyReceiver = getManagedNodeList().get(1);
    VM puneSender = getManagedNodeList().get(2);
    VM puneLocator = Host.getLocator();

    int dsIdPort = puneLocator.invoke(WANManagementDUnitTest::getLocatorPort);

    Integer nyPort = nyLocator.invoke(() -> WANTestBase.createFirstRemoteLocator(12, dsIdPort));

    puneSender.invoke(() -> WANTestBase.createCache(dsIdPort));

    // keep a larger batch to minimize number of exception occurrences in the
    // log
    puneSender
        .invoke(() -> WANTestBase.createSender("pn", 12, true, 100, 300, false, false, null, true));


    puneSender.invoke(() -> WANTestBase.createPartitionedRegion(getTestMethodName() + "_PR", "pn",
        1, 100, false));

    nyReceiver.invoke(() -> WANTestBase.createCache(nyPort));
    nyReceiver.invoke(() -> WANTestBase.createPartitionedRegion(getTestMethodName() + "_PR", null,
        1, 100, false));

    nyReceiver.invoke(WANTestBase::createReceiver);

    puneSender.invoke(() -> WANTestBase.startSender("pn"));

    // make sure the sender is running before doing any puts
    puneSender.invoke(() -> WANTestBase.waitForSenderRunningState("pn"));

    WANTestBase.checkSenderMBean(puneSender, getTestMethodName() + "_PR", true);

    WANTestBase.checkReceiverMBean(nyReceiver);

    nyReceiver.invoke(WANTestBase::stopReceivers);

    WANTestBase.checkSenderMBean(puneSender, getTestMethodName() + "_PR", false);

    int numEventPuts = 10;
    puneSender.invoke(() -> WANTestBase.doPuts(getTestMethodName() + "_PR", numEventPuts));

    puneSender.invoke(() -> WANTestBase.checkQueueSize("pn", 10));

    nyReceiver.invoke(WANTestBase::startReceivers);

    WANTestBase.checkSenderMBean(puneSender, getTestMethodName() + "_PR", true);

    puneSender.invoke(() -> WANTestBase.checkQueueSize("pn", 0));
  }
Tests for WAN artifacts like Sender and Receiver. The purpose of this test is not to check WAN
functionality , but to verify ManagementServices running properly and reflecting WAN behaviour
and data properly
geode-wan/src/distributedTest/java/org/apache/geode/management/WANManagementDUnitTest.java