@Ignore @Test public void test_DR_PGS_4NODES_2NODESDOWN_Validate_Receiver() throws Exception {
  Integer lnPort=(Integer)vm0.invoke(null);
  Integer nyPort=(Integer)vm1.invoke(null);
  createCacheInVMs(nyPort,vm2,vm3);
  createReceiverInVMs(vm2,vm3);
  createCacheInVMs(lnPort,vm4,vm5,vm6,vm7);
  vm4.invoke(null);
  vm5.invoke(null);
  vm6.invoke(null);
  vm7.invoke(null);
  vm4.invoke(null);
  vm5.invoke(null);
  vm6.invoke(null);
  vm7.invoke(null);
  startSenderInVMs("ln",vm4,vm5,vm6,vm7);
  vm2.invoke(null);
  vm3.invoke(null);
  vm4.invoke(null);
  vm5.invoke(null);
  vm6.invoke(null);
  vm7.invoke(null);
  Thread.sleep(60000);
{
    AsyncInvocation inv1=vm7.invokeAsync(null);
    Thread.sleep(1000);
    AsyncInvocation inv2=vm4.invokeAsync(null);
    Thread.sleep(2000);
    AsyncInvocation inv3=vm6.invokeAsync(null);
    Thread.sleep(1500);
    AsyncInvocation inv4=vm5.invokeAsync(null);
    try {
      inv1.join();
      inv2.join();
      inv3.join();
      inv4.join();
    }
 catch (    Exception e) {
      Assert.fail("UnExpected Exception",e);
    }
  }
  vm6.invoke(null);
  vm7.invoke(null);
  vm2.invoke(null);
}

@ Ignore @ Test public void test_DR_PGS_4NODES_2NODESDOWN_Validate_Receiver ( ) throws Exception { Integer lnPort = ( Integer ) vm0 . invoke ( null ) ; Integer nyPort = ( Integer ) vm1 . invoke ( null ) ; createCacheInVMs ( nyPort , vm2 , vm3 ) ; createReceiverInVMs ( vm2 , vm3 ) ; createCacheInVMs ( lnPort , vm4 , vm5 , vm6 , vm7 ) ; vm4 . invoke ( null ) ; vm5 . invoke ( null ) ; vm6 . invoke ( null ) ; vm7 . invoke ( null ) ; vm4 . invoke ( null ) ; vm5 . invoke ( null ) ; vm6 . invoke ( null ) ; vm7 . invoke ( null ) ; startSenderInVMs ( "ln" , vm4 , vm5 , vm6 , vm7 ) ; vm2 . invoke ( null ) ; vm3 . invoke ( null ) ; vm4 . invoke ( null ) ; vm5 . invoke ( null ) ; vm6 . invoke ( null ) ; vm7 . invoke ( null ) ; Thread . sleep ( 60000 ) ; { AsyncInvocation inv1 = vm7 . invokeAsync ( null ) ; Thread . sleep ( 1000 ) ; AsyncInvocation inv2 = vm4 . invokeAsync ( null ) ; Thread . sleep ( 2000 ) ; AsyncInvocation inv3 = vm6 . invokeAsync ( null ) ; Thread . sleep ( 1500 ) ; AsyncInvocation inv4 = vm5 . invokeAsync ( null ) ; try { inv1 . join ( ) ; inv2 . join ( ) ; inv3 . join ( ) ; inv4 . join ( ) ; } catch ( Exception e ) { Assert . fail ( "UnExpected Exception" , e ) ; } } vm6 . invoke ( null ) ; vm7 . invoke ( null ) ; vm2 . invoke ( null ) ; }
below test is disabled intentionally 1 > in this release 8 . 0 , for rolling upgrade support queue name is changed to old style 2 > common parallel sender for different non colocated regions is not supported in 8 . 0 so no need to bother about parallelgatewaysenderqueue # convertpathtoname 3 > we have to enabled it in next release 4 > version based rolling upgrade support should be provided . based on the version of the gemfire qstring should be used between 8 . 0 and version prior to 8 . 0
