public static void checkProxySender(final VM vm, final DistributedMember senderMember) {
    SerializableRunnable checkProxySender = new SerializableRunnable("Check Proxy Sender") {
      @Override
      public void run() {
        ManagementService service = ManagementService.getManagementService(cache);
        GatewaySenderMXBean bean = null;
        try {
          bean = MBeanUtil.getGatewaySenderMbeanProxy(senderMember, "pn");
        } catch (Exception e) {
          fail("Could not obtain Sender Proxy in desired time " + e);
        }
        assertThat(bean).isNotNull();
        final ObjectName senderMBeanName = service.getGatewaySenderMBeanName(senderMember, "pn");
        try {
          MBeanUtil.printBeanDetails(senderMBeanName);
        } catch (Exception e) {
          fail("Error while Printing Bean Details " + e);
        }

        if (service.isManager()) {
          DistributedSystemMXBean dsBean = service.getDistributedSystemMXBean();
          await().untilAsserted(() -> {
            Map<String, Boolean> dsMap = dsBean.viewRemoteClusterStatus();
            assertThat(dsMap).doesNotContainValue(false);
            // dsMap.entrySet().forEach(entry -> assertThat(entry.getValue()).as(
            // "Should be true " + entry.getKey()).isTrue());
          });
        }

      }
    };
    vm.invoke(checkProxySender);
  }
Checks Proxy GatewaySender

@param vm reference to VM
geode-wan/src/distributedTest/java/org/apache/geode/internal/cache/wan/WANTestBase.java