geode-wan/src/test/java/org/apache/geode/management/internal/pulse/TestRemoteClusterDUnitTest.java
@SuppressWarnings("serial")
  protected void checkReceiverMBean(final VM vm) {
    SerializableRunnable checkMBean = new SerializableRunnable("Check Receiver MBean") {
      public void run() {
        Cache cache = GemFireCacheImpl.getInstance();
        ManagementService service = ManagementService.getManagementService(cache);
        GatewayReceiverMXBean bean = service.getLocalGatewayReceiverMXBean();
        assertNotNull(bean);
      }
    };
    vm.invoke(checkMBean);
  }
/**
   * Checks whether a GatewayReceiverMBean is created or not
   * 
   * @param vm reference to VM
   */
Checks whether a GatewayReceiverMBean is created or not

@param vm reference to VM
Checks whether a GatewayReceiverMBean is created or not @param vm reference to VM
@SuppressWarnings("serial")
  protected void checkReceiverMBean(final VM vm) {
    SerializableRunnable checkMBean = new SerializableRunnable("Check Receiver MBean") {
      public void run() {
        Cache cache = GemFireCacheImpl.getInstance();
        ManagementService service = ManagementService.getManagementService(cache);
        GatewayReceiverMXBean bean = service.getLocalGatewayReceiverMXBean();
        assertNotNull(bean);
      }
    };
    vm.invoke(checkMBean);
  }
@ SuppressWarnings ( "serial" ) protected void checkReceiverMBean ( final VM vm ) { SerializableRunnable checkMBean = new SerializableRunnable ( "Check Receiver MBean" ) { public void run ( ) { Cache cache = GemFireCacheImpl . getInstance ( ) ; ManagementService service = ManagementService . getManagementService ( cache ) ; GatewayReceiverMXBean bean = service . getLocalGatewayReceiverMXBean ( ) ; assertNotNull ( bean ) ; } } ; vm . invoke ( checkMBean ) ; }
Checks whether a GatewayReceiverMBean is created or not
Checks whether a GatewayReceiverMBean is created or not