geode-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kl...@apache.org
Subject [44/46] geode git commit: Fix formatting
Date Mon, 12 Dec 2016 22:36:47 GMT
http://git-wip-us.apache.org/repos/asf/geode/blob/d261061e/geode-core/src/test/java/org/apache/geode/management/RegionManagementDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/org/apache/geode/management/RegionManagementDUnitTest.java b/geode-core/src/test/java/org/apache/geode/management/RegionManagementDUnitTest.java
index 92624a4..3dc92b6 100644
--- a/geode-core/src/test/java/org/apache/geode/management/RegionManagementDUnitTest.java
+++ b/geode-core/src/test/java/org/apache/geode/management/RegionManagementDUnitTest.java
@@ -13,20 +13,18 @@
  * the License.
  */
 /*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
+ * Licensed to the Apache Software Foundation (ASF) under one or more contributor license
+ * agreements. See the NOTICE file distributed with this work for additional information regarding
+ * copyright ownership. The ASF licenses this file to You under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance with the License. You may obtain a
+ * copy of the License at
  *
- *      http://www.apache.org/licenses/LICENSE-2.0
+ * http://www.apache.org/licenses/LICENSE-2.0
  *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
+ * Unless required by applicable law or agreed to in writing, software distributed under the License
+ * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
+ * or implied. See the License for the specific language governing permissions and limitations under
+ * the License.
  */
 package org.apache.geode.management;
 
@@ -85,14 +83,14 @@ import org.apache.geode.test.dunit.WaitCriterion;
 import org.apache.geode.test.junit.categories.DistributedTest;
 
 /**
- * This class checks and verifies various data and operations exposed through
- * RegionMXBean interface.
+ * This class checks and verifies various data and operations exposed through RegionMXBean
+ * interface.
  * <p>
- * Goal of the Test : RegionMBean gets created once region is created. Data like
- * Region Attributes data and stats are of proper value
+ * Goal of the Test : RegionMBean gets created once region is created. Data like Region Attributes
+ * data and stats are of proper value
  */
 @Category(DistributedTest.class)
-@SuppressWarnings({ "serial", "unused" })
+@SuppressWarnings({"serial", "unused"})
 public class RegionManagementDUnitTest extends ManagementTestBase {
 
   private static final String REGION_NAME = "MANAGEMENT_TEST_REGION";
@@ -104,13 +102,16 @@ public class RegionManagementDUnitTest extends ManagementTestBase {
   private static final String REGION_PATH = SEPARATOR + REGION_NAME;
   private static final String PARTITIONED_REGION_PATH = SEPARATOR + PARTITIONED_REGION_NAME;
   private static final String FIXED_PR_PATH = SEPARATOR + FIXED_PR_NAME;
-  private static final String LOCAL_SUB_REGION_PATH = SEPARATOR + LOCAL_REGION_NAME + SEPARATOR + LOCAL_SUB_REGION_NAME;
+  private static final String LOCAL_SUB_REGION_PATH =
+      SEPARATOR + LOCAL_REGION_NAME + SEPARATOR + LOCAL_SUB_REGION_NAME;
 
   // field used in manager VM
   private static Region fixedPartitionedRegion;
 
-  private static final AtomicReference<List<Notification>> MEMBER_NOTIFICATIONS_REF = new AtomicReference<>();
-  private static final AtomicReference<List<Notification>> SYSTEM_NOTIFICATIONS_REF = new AtomicReference<>();
+  private static final AtomicReference<List<Notification>> MEMBER_NOTIFICATIONS_REF =
+      new AtomicReference<>();
+  private static final AtomicReference<List<Notification>> SYSTEM_NOTIFICATIONS_REF =
+      new AtomicReference<>();
 
   @Manager
   private VM managerVM;
@@ -231,12 +232,13 @@ public class RegionManagementDUnitTest extends ManagementTestBase {
 
     int primaryIndex = 0;
     for (VM memberVM : this.memberVMs) {
-      List<FixedPartitionAttributes> fixedPartitionAttributesList = createFixedPartitionList(primaryIndex + 1);
+      List<FixedPartitionAttributes> fixedPartitionAttributesList =
+          createFixedPartitionList(primaryIndex + 1);
       memberVM.invoke(() -> createFixedPartitionRegion(fixedPartitionAttributesList));
       primaryIndex++;
     }
 
-//    // TODO: Workaround for bug 46683. Reenable validation when bug is fixed.
+    // // TODO: Workaround for bug 46683. Reenable validation when bug is fixed.
     verifyRemoteFixedPartitionRegion(this.managerVM);
 
     for (VM memberVM : this.memberVMs) {
@@ -247,8 +249,8 @@ public class RegionManagementDUnitTest extends ManagementTestBase {
   }
 
   /**
-   * Tests a Distributed Region at Managing Node side
-   * while region is created in a member node asynchronously.
+   * Tests a Distributed Region at Managing Node side while region is created in a member node
+   * asynchronously.
    */
   @Test
   public void testRegionAggregate() throws Exception {
@@ -365,11 +367,13 @@ public class RegionManagementDUnitTest extends ManagementTestBase {
     memberVM.invoke("createDiskRegion", () -> {
       AttributesFactory factory = new AttributesFactory();
       factory.setScope(Scope.LOCAL);
-      factory.setEvictionAttributes(EvictionAttributes.createLRUMemoryAttributes(20, new TestObjectSizerImpl(), EvictionAction.LOCAL_DESTROY));
+      factory.setEvictionAttributes(EvictionAttributes.createLRUMemoryAttributes(20,
+          new TestObjectSizerImpl(), EvictionAction.LOCAL_DESTROY));
 
       Region region = getCache_tmp().createRegion(REGION_NAME, factory.create());
 
-      LRUStatistics lruStats = ((AbstractRegion) region).getEvictionController().getLRUHelper().getStats();
+      LRUStatistics lruStats =
+          ((AbstractRegion) region).getEvictionController().getLRUHelper().getStats();
       assertThat(lruStats).isNotNull();
 
       RegionMXBean regionMXBean = getManagementService_tmp().getLocalRegionMBean(REGION_PATH);
@@ -387,7 +391,8 @@ public class RegionManagementDUnitTest extends ManagementTestBase {
 
   private void verifyEntrySize(final VM managerVM, final int expectedMembers) throws Exception {
     managerVM.invoke("verifyEntrySize", () -> {
-      DistributedRegionMXBean distributedRegionMXBean = awaitDistributedRegionMXBean(REGION_PATH, expectedMembers);
+      DistributedRegionMXBean distributedRegionMXBean =
+          awaitDistributedRegionMXBean(REGION_PATH, expectedMembers);
       assertThat(distributedRegionMXBean).isNotNull();
       assertThat(distributedRegionMXBean.getEntrySize()).isGreaterThan(0);
     });
@@ -417,11 +422,14 @@ public class RegionManagementDUnitTest extends ManagementTestBase {
       DistributedSystemMXBean distributedSystemMXBean = service.getDistributedSystemMXBean();
       assertThat(distributedSystemMXBean.listDistributedRegionObjectNames()).hasSize(2);
 
-      assertThat(distributedSystemMXBean.fetchDistributedRegionObjectName(PARTITIONED_REGION_PATH)).isNotNull();
+      assertThat(distributedSystemMXBean.fetchDistributedRegionObjectName(PARTITIONED_REGION_PATH))
+          .isNotNull();
       assertThat(distributedSystemMXBean.fetchDistributedRegionObjectName(REGION_PATH)).isNotNull();
 
-      ObjectName actualName = distributedSystemMXBean.fetchDistributedRegionObjectName(PARTITIONED_REGION_PATH);
-      ObjectName expectedName = MBeanJMXAdapter.getDistributedRegionMbeanName(PARTITIONED_REGION_PATH);
+      ObjectName actualName =
+          distributedSystemMXBean.fetchDistributedRegionObjectName(PARTITIONED_REGION_PATH);
+      ObjectName expectedName =
+          MBeanJMXAdapter.getDistributedRegionMbeanName(PARTITIONED_REGION_PATH);
       assertThat(actualName).isEqualTo(expectedName);
 
       actualName = distributedSystemMXBean.fetchDistributedRegionObjectName(REGION_PATH);
@@ -452,7 +460,8 @@ public class RegionManagementDUnitTest extends ManagementTestBase {
         expectedName = MBeanJMXAdapter.getRegionMBeanName(memberId, PARTITIONED_REGION_PATH);
         awaitRegionMXBeanProxy(expectedName);
 
-        actualName = distributedSystemMXBean.fetchRegionObjectName(memberId, PARTITIONED_REGION_PATH);
+        actualName =
+            distributedSystemMXBean.fetchRegionObjectName(memberId, PARTITIONED_REGION_PATH);
         assertThat(actualName).isEqualTo(expectedName);
 
         expectedName = MBeanJMXAdapter.getRegionMBeanName(memberId, REGION_PATH);
@@ -470,19 +479,22 @@ public class RegionManagementDUnitTest extends ManagementTestBase {
   private List<FixedPartitionAttributes> createFixedPartitionList(final int primaryIndex) {
     List<FixedPartitionAttributes> fixedPartitionAttributesList = new ArrayList<>();
     if (primaryIndex == 1) {
-      fixedPartitionAttributesList.add(FixedPartitionAttributes.createFixedPartition("Q1", true, 3));
+      fixedPartitionAttributesList
+          .add(FixedPartitionAttributes.createFixedPartition("Q1", true, 3));
       fixedPartitionAttributesList.add(FixedPartitionAttributes.createFixedPartition("Q2", 3));
       fixedPartitionAttributesList.add(FixedPartitionAttributes.createFixedPartition("Q3", 3));
     }
     if (primaryIndex == 2) {
       fixedPartitionAttributesList.add(FixedPartitionAttributes.createFixedPartition("Q1", 3));
-      fixedPartitionAttributesList.add(FixedPartitionAttributes.createFixedPartition("Q2", true, 3));
+      fixedPartitionAttributesList
+          .add(FixedPartitionAttributes.createFixedPartition("Q2", true, 3));
       fixedPartitionAttributesList.add(FixedPartitionAttributes.createFixedPartition("Q3", 3));
     }
     if (primaryIndex == 3) {
       fixedPartitionAttributesList.add(FixedPartitionAttributes.createFixedPartition("Q1", 3));
       fixedPartitionAttributesList.add(FixedPartitionAttributes.createFixedPartition("Q2", 3));
-      fixedPartitionAttributesList.add(FixedPartitionAttributes.createFixedPartition("Q3", true, 3));
+      fixedPartitionAttributesList
+          .add(FixedPartitionAttributes.createFixedPartition("Q3", true, 3));
     }
     return fixedPartitionAttributesList;
   }
@@ -490,7 +502,8 @@ public class RegionManagementDUnitTest extends ManagementTestBase {
   /**
    * Invoked in member VMs
    */
-  private void createFixedPartitionRegion(final List<FixedPartitionAttributes> fixedPartitionAttributesList) {
+  private void createFixedPartitionRegion(
+      final List<FixedPartitionAttributes> fixedPartitionAttributesList) {
     SystemManagementService service = getSystemManagementService_tmp();
 
     PartitionAttributesFactory partitionAttributesFactory = new PartitionAttributesFactory();
@@ -513,38 +526,43 @@ public class RegionManagementDUnitTest extends ManagementTestBase {
     PartitionAttributesData partitionAttributesData = regionMXBean.listPartitionAttributes();
     verifyPartitionData(regionAttributes, partitionAttributesData);
 
-    FixedPartitionAttributesData[] fixedPartitionAttributesData = regionMXBean.listFixedPartitionAttributes();
+    FixedPartitionAttributesData[] fixedPartitionAttributesData =
+        regionMXBean.listFixedPartitionAttributes();
     assertThat(fixedPartitionAttributesData).isNotNull();
     assertThat(fixedPartitionAttributesData).hasSize(3);
 
     for (int i = 0; i < fixedPartitionAttributesData.length; i++) {
-      //LogWriterUtils.getLogWriter().info("<ExpectedString> Fixed PR Data is " + fixedPartitionAttributesData[i] + "</ExpectedString> ");
+      // LogWriterUtils.getLogWriter().info("<ExpectedString> Fixed PR Data is " +
+      // fixedPartitionAttributesData[i] + "</ExpectedString> ");
     }
   }
 
-//  /**
-//   * Invoked in manager VM
-//   */
-//  private void verifyRemoteFixedPartitionRegion(final VM vm) throws Exception {
-//    vm.invoke("Verify Partition region", () -> {
-//      Set<DistributedMember> otherMemberSet = getDistributionManager_tmp().getOtherNormalDistributionManagerIds();
-//
-//      for (DistributedMember member : otherMemberSet) {
-//        RegionMXBean regionMXBean = awaitRegionMXBeanProxy(member, FIXED_PR_PATH);
-//
-//        PartitionAttributesData partitionAttributesData = regionMXBean.listPartitionAttributes();
-//        assertNotNull(partitionAttributesData);
-//
-//        FixedPartitionAttributesData[] fixedPartitionAttributesData = regionMXBean.listFixedPartitionAttributes();
-//        assertNotNull(fixedPartitionAttributesData);
-//        assertEquals(3, fixedPartitionAttributesData.length);
-//
-//        for (int i = 0; i < fixedPartitionAttributesData.length; i++) {
-//          //LogWriterUtils.getLogWriter().info("<ExpectedString> Remote PR Data is " + fixedPartitionAttributesData[i] + "</ExpectedString> ");
-//        }
-//      }
-//    });
-//  }
+  // /**
+  // * Invoked in manager VM
+  // */
+  // private void verifyRemoteFixedPartitionRegion(final VM vm) throws Exception {
+  // vm.invoke("Verify Partition region", () -> {
+  // Set<DistributedMember> otherMemberSet =
+  // getDistributionManager_tmp().getOtherNormalDistributionManagerIds();
+  //
+  // for (DistributedMember member : otherMemberSet) {
+  // RegionMXBean regionMXBean = awaitRegionMXBeanProxy(member, FIXED_PR_PATH);
+  //
+  // PartitionAttributesData partitionAttributesData = regionMXBean.listPartitionAttributes();
+  // assertNotNull(partitionAttributesData);
+  //
+  // FixedPartitionAttributesData[] fixedPartitionAttributesData =
+  // regionMXBean.listFixedPartitionAttributes();
+  // assertNotNull(fixedPartitionAttributesData);
+  // assertEquals(3, fixedPartitionAttributesData.length);
+  //
+  // for (int i = 0; i < fixedPartitionAttributesData.length; i++) {
+  // //LogWriterUtils.getLogWriter().info("<ExpectedString> Remote PR Data is " +
+  // fixedPartitionAttributesData[i] + "</ExpectedString> ");
+  // }
+  // }
+  // });
+  // }
 
   private void addMemberNotificationListener(final VM managerVM, final int expectedMembers) {
     managerVM.invoke("addMemberNotificationListener", () -> {
@@ -561,16 +579,16 @@ public class RegionManagementDUnitTest extends ManagementTestBase {
         ObjectName objectName = service.getMemberMBeanName(member);
         awaitMemberMXBeanProxy(objectName);
 
-        ManagementFactory.getPlatformMBeanServer().addNotificationListener(objectName, listener, null, null);
+        ManagementFactory.getPlatformMBeanServer().addNotificationListener(objectName, listener,
+            null, null);
       }
     });
   }
 
   /**
-   * Add a Notification listener to DistributedSystemMBean which should gather
-   * all the notifications which are propagated through all individual
-   * MemberMBeans Hence Region created/destroyed should be visible to this
-   * listener
+   * Add a Notification listener to DistributedSystemMBean which should gather all the notifications
+   * which are propagated through all individual MemberMBeans Hence Region created/destroyed should
+   * be visible to this listener
    */
   private void addSystemNotificationListener(final VM managerVM) {
     managerVM.invoke("addSystemNotificationListener", () -> {
@@ -579,13 +597,16 @@ public class RegionManagementDUnitTest extends ManagementTestBase {
       List<Notification> notifications = new ArrayList<>();
       SYSTEM_NOTIFICATIONS_REF.set(notifications);
 
-      DistributedSystemNotificationListener listener = new DistributedSystemNotificationListener(notifications);
+      DistributedSystemNotificationListener listener =
+          new DistributedSystemNotificationListener(notifications);
       ObjectName objectName = MBeanJMXAdapter.getDistributedSystemName();
-      ManagementFactory.getPlatformMBeanServer().addNotificationListener(objectName, listener, null, null);
+      ManagementFactory.getPlatformMBeanServer().addNotificationListener(objectName, listener, null,
+          null);
     });
   }
 
-  private void verifyMemberNotifications(final VM managerVM, final String regionName, final int expectedMembers) {
+  private void verifyMemberNotifications(final VM managerVM, final String regionName,
+      final int expectedMembers) {
     managerVM.invoke("verifyMemberNotifications", () -> {
       assertThat(MEMBER_NOTIFICATIONS_REF.get()).isNotNull();
       assertThat(MEMBER_NOTIFICATIONS_REF.get()).hasSize(expectedMembers * 2);
@@ -609,14 +630,21 @@ public class RegionManagementDUnitTest extends ManagementTestBase {
     });
   }
 
-  //  <[javax.management.Notification[source=10.118.33.232(17632)<v1>-32770][type=gemfire.distributedsystem.cache.region.created][message=Region Created With Name /MANAGEMENT_TEST_REGION],
-  //  javax.management.Notification[source=10.118.33.232(17633)<v2>-32771][type=gemfire.distributedsystem.cache.region.created][message=Region Created With Name /MANAGEMENT_TEST_REGION],
-  //  javax.management.Notification[source=10.118.33.232(17634)<v3>-32772][type=gemfire.distributedsystem.cache.region.created][message=Region Created With Name /MANAGEMENT_TEST_REGION],
-  //  javax.management.Notification[source=10.118.33.232(17632)<v1>-32770][type=gemfire.distributedsystem.cache.region.closed][message=Region Destroyed/Closed With Name /MANAGEMENT_TEST_REGION],
-  //  javax.management.Notification[source=10.118.33.232(17633)<v2>-32771][type=gemfire.distributedsystem.cache.region.closed][message=Region Destroyed/Closed With Name /MANAGEMENT_TEST_REGION],
-  //  javax.management.Notification[source=10.118.33.232(17634)<v3>-32772][type=gemfire.distributedsystem.cache.region.closed][message=Region Destroyed/Closed With Name /MANAGEMENT_TEST_REGION]]>
-
-  private void verifySystemNotifications(final VM managerVM, final String regionName, final int expectedMembers) {
+  // <[javax.management.Notification[source=10.118.33.232(17632)<v1>-32770][type=gemfire.distributedsystem.cache.region.created][message=Region
+  // Created With Name /MANAGEMENT_TEST_REGION],
+  // javax.management.Notification[source=10.118.33.232(17633)<v2>-32771][type=gemfire.distributedsystem.cache.region.created][message=Region
+  // Created With Name /MANAGEMENT_TEST_REGION],
+  // javax.management.Notification[source=10.118.33.232(17634)<v3>-32772][type=gemfire.distributedsystem.cache.region.created][message=Region
+  // Created With Name /MANAGEMENT_TEST_REGION],
+  // javax.management.Notification[source=10.118.33.232(17632)<v1>-32770][type=gemfire.distributedsystem.cache.region.closed][message=Region
+  // Destroyed/Closed With Name /MANAGEMENT_TEST_REGION],
+  // javax.management.Notification[source=10.118.33.232(17633)<v2>-32771][type=gemfire.distributedsystem.cache.region.closed][message=Region
+  // Destroyed/Closed With Name /MANAGEMENT_TEST_REGION],
+  // javax.management.Notification[source=10.118.33.232(17634)<v3>-32772][type=gemfire.distributedsystem.cache.region.closed][message=Region
+  // Destroyed/Closed With Name /MANAGEMENT_TEST_REGION]]>
+
+  private void verifySystemNotifications(final VM managerVM, final String regionName,
+      final int expectedMembers) {
     managerVM.invoke("verifySystemNotifications", () -> {
       assertThat(SYSTEM_NOTIFICATIONS_REF.get()).isNotNull();
       assertThat(SYSTEM_NOTIFICATIONS_REF.get()).hasSize(expectedMembers + 2); // 2 for the manager
@@ -641,11 +669,16 @@ public class RegionManagementDUnitTest extends ManagementTestBase {
     });
   }
 
-  //  <[javax.management.Notification[source=192.168.1.72(18496)<v27>-32770][type=gemfire.distributedsystem.cache.region.created][message=Region Created With Name /MANAGEMENT_TEST_REGION],
-  //  javax.management.Notification[source=192.168.1.72(18497)<v28>-32771][type=gemfire.distributedsystem.cache.region.closed][message=Region Destroyed/Closed With Name /MANAGEMENT_TEST_REGION],
-  //  javax.management.Notification[source=192.168.1.72(18498)<v29>-32772][type=gemfire.distributedsystem.cache.region.closed][message=Region Destroyed/Closed With Name /MANAGEMENT_TEST_REGION],
-  //  javax.management.Notification[source=192.168.1.72(18499)<v30>-32773][type=gemfire.distributedsystem.cache.region.closed][message=Region Destroyed/Closed With Name /MANAGEMENT_TEST_REGION],
-  //  javax.management.Notification[source=192.168.1.72(18496)<v27>-32770][type=gemfire.distributedsystem.cache.region.closed][message=Region Destroyed/Closed With Name /MANAGEMENT_TEST_REGION]]>
+  // <[javax.management.Notification[source=192.168.1.72(18496)<v27>-32770][type=gemfire.distributedsystem.cache.region.created][message=Region
+  // Created With Name /MANAGEMENT_TEST_REGION],
+  // javax.management.Notification[source=192.168.1.72(18497)<v28>-32771][type=gemfire.distributedsystem.cache.region.closed][message=Region
+  // Destroyed/Closed With Name /MANAGEMENT_TEST_REGION],
+  // javax.management.Notification[source=192.168.1.72(18498)<v29>-32772][type=gemfire.distributedsystem.cache.region.closed][message=Region
+  // Destroyed/Closed With Name /MANAGEMENT_TEST_REGION],
+  // javax.management.Notification[source=192.168.1.72(18499)<v30>-32773][type=gemfire.distributedsystem.cache.region.closed][message=Region
+  // Destroyed/Closed With Name /MANAGEMENT_TEST_REGION],
+  // javax.management.Notification[source=192.168.1.72(18496)<v27>-32770][type=gemfire.distributedsystem.cache.region.closed][message=Region
+  // Destroyed/Closed With Name /MANAGEMENT_TEST_REGION]]>
 
   private void verifyProxyCleanup(final VM managerVM) {
     managerVM.invoke("verifyProxyCleanup", () -> {
@@ -654,12 +687,15 @@ public class RegionManagementDUnitTest extends ManagementTestBase {
       Set<DistributedMember> otherMemberSet = getOtherNormalMembers_tmp();
       for (final DistributedMember member : otherMemberSet) {
         String alias = "Waiting for the proxy to get deleted at managing node";
-        await(alias).until(() -> assertThat(service.getMBeanProxy(service.getRegionMBeanName(member, REGION_PATH), RegionMXBean.class)).isNull());
+        await(alias).until(
+            () -> assertThat(service.getMBeanProxy(service.getRegionMBeanName(member, REGION_PATH),
+                RegionMXBean.class)).isNull());
       }
     });
   }
 
-  private void verifyRemoteDistributedRegion(final VM managerVM, final int expectedMembers) throws Exception {
+  private void verifyRemoteDistributedRegion(final VM managerVM, final int expectedMembers)
+      throws Exception {
     managerVM.invoke("verifyRemoteDistributedRegion", () -> {
       Set<DistributedMember> otherMemberSet = getOtherNormalMembers_tmp();
       assertThat(otherMemberSet).hasSize(expectedMembers);
@@ -677,7 +713,8 @@ public class RegionManagementDUnitTest extends ManagementTestBase {
         assertThat(evictionAttributesData).isNotNull();
       }
 
-      DistributedRegionMXBean distributedRegionMXBean = awaitDistributedRegionMXBean(REGION_PATH, expectedMembers);
+      DistributedRegionMXBean distributedRegionMXBean =
+          awaitDistributedRegionMXBean(REGION_PATH, expectedMembers);
 
       assertThat(distributedRegionMXBean).isNotNull();
       assertThat(distributedRegionMXBean.getFullPath()).isEqualTo(REGION_PATH);
@@ -689,20 +726,25 @@ public class RegionManagementDUnitTest extends ManagementTestBase {
       if (expectedMembers == 0) {
         ManagementService service = getManagementService_tmp();
         String alias = "Waiting for the proxy to get deleted at managing node";
-        await(alias).until(() -> assertThat(service.getDistributedRegionMXBean(REGION_PATH)).isNull());
+        await(alias)
+            .until(() -> assertThat(service.getDistributedRegionMXBean(REGION_PATH)).isNull());
         return;
       }
 
-      DistributedRegionMXBean distributedRegionMXBean = awaitDistributedRegionMXBean(REGION_PATH, expectedMembers);
+      DistributedRegionMXBean distributedRegionMXBean =
+          awaitDistributedRegionMXBean(REGION_PATH, expectedMembers);
 
       assertThat(distributedRegionMXBean.getFullPath()).isEqualTo(REGION_PATH);
       assertThat(distributedRegionMXBean.getMemberCount()).isEqualTo(expectedMembers);
       assertThat(distributedRegionMXBean.getMembers()).hasSize(expectedMembers);
 
       // Check Stats related Data
-      //LogWriterUtils.getLogWriter().info("<ExpectedString> CacheListenerCallsAvgLatency is " + distributedRegionMXBean.getCacheListenerCallsAvgLatency() + "</ExpectedString> ");
-      //LogWriterUtils.getLogWriter().info("<ExpectedString> CacheWriterCallsAvgLatency is " + distributedRegionMXBean.getCacheWriterCallsAvgLatency() + "</ExpectedString> ");
-      //LogWriterUtils.getLogWriter().info("<ExpectedString> CreatesRate is " + distributedRegionMXBean.getCreatesRate() + "</ExpectedString> ");
+      // LogWriterUtils.getLogWriter().info("<ExpectedString> CacheListenerCallsAvgLatency is " +
+      // distributedRegionMXBean.getCacheListenerCallsAvgLatency() + "</ExpectedString> ");
+      // LogWriterUtils.getLogWriter().info("<ExpectedString> CacheWriterCallsAvgLatency is " +
+      // distributedRegionMXBean.getCacheWriterCallsAvgLatency() + "</ExpectedString> ");
+      // LogWriterUtils.getLogWriter().info("<ExpectedString> CreatesRate is " +
+      // distributedRegionMXBean.getCreatesRate() + "</ExpectedString> ");
     });
   }
 
@@ -717,7 +759,8 @@ public class RegionManagementDUnitTest extends ManagementTestBase {
       }
 
       ManagementService service = getManagementService_tmp();
-      DistributedRegionMXBean distributedRegionMXBean = service.getDistributedRegionMXBean(PARTITIONED_REGION_PATH);
+      DistributedRegionMXBean distributedRegionMXBean =
+          service.getDistributedRegionMXBean(PARTITIONED_REGION_PATH);
       assertThat(distributedRegionMXBean.getMembers()).hasSize(3);
     });
   }
@@ -726,14 +769,16 @@ public class RegionManagementDUnitTest extends ManagementTestBase {
     memberVM.invoke("verifyReplicateRegionAfterCreate", () -> {
       Cache cache = getCache_tmp();
 
-      String memberId = MBeanJMXAdapter.getMemberNameOrId(cache.getDistributedSystem().getDistributedMember());
+      String memberId =
+          MBeanJMXAdapter.getMemberNameOrId(cache.getDistributedSystem().getDistributedMember());
       ObjectName objectName = ObjectName.getInstance("GemFire:type=Member,member=" + memberId);
 
-//      List<Notification> notifications = new ArrayList<>();
-//      MEMBER_NOTIFICATIONS_REF.set(notifications);
-//
-//      MemberNotificationListener listener = new MemberNotificationListener(notifications);
-//      ManagementFactory.getPlatformMBeanServer().addNotificationListener(objectName, listener, null, null);
+      // List<Notification> notifications = new ArrayList<>();
+      // MEMBER_NOTIFICATIONS_REF.set(notifications);
+      //
+      // MemberNotificationListener listener = new MemberNotificationListener(notifications);
+      // ManagementFactory.getPlatformMBeanServer().addNotificationListener(objectName, listener,
+      // null, null);
 
       SystemManagementService service = getSystemManagementService_tmp();
       RegionMXBean regionMXBean = service.getLocalRegionMBean(REGION_PATH);
@@ -770,8 +815,10 @@ public class RegionManagementDUnitTest extends ManagementTestBase {
       RegionMXBean regionMXBean = service.getLocalRegionMBean(REGION_PATH);
       assertThat(regionMXBean).isNull();
 
-      ObjectName objectName = service.getRegionMBeanName(getCache_tmp().getDistributedSystem().getDistributedMember(), REGION_PATH);
-      assertThat(service.getLocalManager().getManagementResourceRepo().getEntryFromLocalMonitoringRegion(objectName)).isNull();
+      ObjectName objectName = service.getRegionMBeanName(
+          getCache_tmp().getDistributedSystem().getDistributedMember(), REGION_PATH);
+      assertThat(service.getLocalManager().getManagementResourceRepo()
+          .getEntryFromLocalMonitoringRegion(objectName)).isNull();
     });
   }
 
@@ -786,35 +833,46 @@ public class RegionManagementDUnitTest extends ManagementTestBase {
   /**
    * Invoked in member VMs
    */
-  private void verifyPartitionData(final RegionAttributes expectedRegionAttributes, final PartitionAttributesData partitionAttributesData) {
-    PartitionAttributes expectedPartitionAttributes = expectedRegionAttributes.getPartitionAttributes();
+  private void verifyPartitionData(final RegionAttributes expectedRegionAttributes,
+      final PartitionAttributesData partitionAttributesData) {
+    PartitionAttributes expectedPartitionAttributes =
+        expectedRegionAttributes.getPartitionAttributes();
 
-    assertThat(partitionAttributesData.getRedundantCopies()).isEqualTo(expectedPartitionAttributes.getRedundantCopies());
+    assertThat(partitionAttributesData.getRedundantCopies())
+        .isEqualTo(expectedPartitionAttributes.getRedundantCopies());
 
-    assertThat(partitionAttributesData.getTotalMaxMemory()).isEqualTo(expectedPartitionAttributes.getTotalMaxMemory());
+    assertThat(partitionAttributesData.getTotalMaxMemory())
+        .isEqualTo(expectedPartitionAttributes.getTotalMaxMemory());
 
     // Total number of buckets for whole region
-    assertThat(partitionAttributesData.getTotalNumBuckets()).isEqualTo(expectedPartitionAttributes.getTotalNumBuckets());
+    assertThat(partitionAttributesData.getTotalNumBuckets())
+        .isEqualTo(expectedPartitionAttributes.getTotalNumBuckets());
 
-    assertThat(partitionAttributesData.getLocalMaxMemory()).isEqualTo(expectedPartitionAttributes.getLocalMaxMemory());
+    assertThat(partitionAttributesData.getLocalMaxMemory())
+        .isEqualTo(expectedPartitionAttributes.getLocalMaxMemory());
 
-    assertThat(partitionAttributesData.getColocatedWith()).isEqualTo(expectedPartitionAttributes.getColocatedWith());
+    assertThat(partitionAttributesData.getColocatedWith())
+        .isEqualTo(expectedPartitionAttributes.getColocatedWith());
 
     String partitionResolver = null;
-    if (expectedPartitionAttributes.getPartitionResolver() != null) { // TODO: these conditionals should be deterministic
+    if (expectedPartitionAttributes.getPartitionResolver() != null) { // TODO: these conditionals
+                                                                      // should be deterministic
       partitionResolver = expectedPartitionAttributes.getPartitionResolver().getName();
     }
     assertThat(partitionAttributesData.getPartitionResolver()).isEqualTo(partitionResolver);
 
-    assertThat(partitionAttributesData.getRecoveryDelay()).isEqualTo(expectedPartitionAttributes.getRecoveryDelay());
+    assertThat(partitionAttributesData.getRecoveryDelay())
+        .isEqualTo(expectedPartitionAttributes.getRecoveryDelay());
 
-    assertThat(partitionAttributesData.getStartupRecoveryDelay()).isEqualTo(expectedPartitionAttributes.getStartupRecoveryDelay());
+    assertThat(partitionAttributesData.getStartupRecoveryDelay())
+        .isEqualTo(expectedPartitionAttributes.getStartupRecoveryDelay());
 
     if (expectedPartitionAttributes.getPartitionListeners() != null) {
       for (int i = 0; i < expectedPartitionAttributes.getPartitionListeners().length; i++) {
-        //assertEquals((expectedPartitionAttributes.getPartitionListeners())[i].getClass().getCanonicalName(), partitionAttributesData.getPartitionListeners()[i]);
-        assertThat(partitionAttributesData.getPartitionListeners()[i])
-          .isEqualTo(expectedPartitionAttributes.getPartitionListeners()[i].getClass().getCanonicalName());
+        // assertEquals((expectedPartitionAttributes.getPartitionListeners())[i].getClass().getCanonicalName(),
+        // partitionAttributesData.getPartitionListeners()[i]);
+        assertThat(partitionAttributesData.getPartitionListeners()[i]).isEqualTo(
+            expectedPartitionAttributes.getPartitionListeners()[i].getClass().getCanonicalName());
 
       }
     }
@@ -823,9 +881,11 @@ public class RegionManagementDUnitTest extends ManagementTestBase {
   /**
    * Invoked in member VMs
    */
-  private void verifyRegionAttributes(final RegionAttributes regionAttributes, final RegionAttributesData regionAttributesData) {
+  private void verifyRegionAttributes(final RegionAttributes regionAttributes,
+      final RegionAttributesData regionAttributesData) {
     String compressorClassName = null;
-    if (regionAttributes.getCompressor() != null) { // TODO: these conditionals should be deterministic
+    if (regionAttributes.getCompressor() != null) { // TODO: these conditionals should be
+                                                    // deterministic
       compressorClassName = regionAttributes.getCompressor().getClass().getCanonicalName();
     }
     assertThat(regionAttributesData.getCompressorClassName()).isEqualTo(compressorClassName);
@@ -852,7 +912,8 @@ public class RegionManagementDUnitTest extends ManagementTestBase {
     if (regionAttributes.getValueConstraint() != null) {
       valueContstaintClassName = regionAttributes.getValueConstraint().getName();
     }
-    assertThat(regionAttributesData.getValueConstraintClassName()).isEqualTo(valueContstaintClassName);
+    assertThat(regionAttributesData.getValueConstraintClassName())
+        .isEqualTo(valueContstaintClassName);
 
     CacheListener[] listeners = regionAttributes.getCacheListeners();
     if (listeners != null) {
@@ -862,13 +923,17 @@ public class RegionManagementDUnitTest extends ManagementTestBase {
       }
     }
 
-    assertThat(regionAttributesData.getRegionTimeToLive()).isEqualTo(regionAttributes.getRegionTimeToLive().getTimeout());
+    assertThat(regionAttributesData.getRegionTimeToLive())
+        .isEqualTo(regionAttributes.getRegionTimeToLive().getTimeout());
 
-    assertThat(regionAttributesData.getRegionIdleTimeout()).isEqualTo(regionAttributes.getRegionIdleTimeout().getTimeout());
+    assertThat(regionAttributesData.getRegionIdleTimeout())
+        .isEqualTo(regionAttributes.getRegionIdleTimeout().getTimeout());
 
-    assertThat(regionAttributesData.getEntryTimeToLive()).isEqualTo(regionAttributes.getEntryTimeToLive().getTimeout());
+    assertThat(regionAttributesData.getEntryTimeToLive())
+        .isEqualTo(regionAttributes.getEntryTimeToLive().getTimeout());
 
-    assertThat(regionAttributesData.getEntryIdleTimeout()).isEqualTo(regionAttributes.getEntryIdleTimeout().getTimeout());
+    assertThat(regionAttributesData.getEntryIdleTimeout())
+        .isEqualTo(regionAttributes.getEntryIdleTimeout().getTimeout());
 
     String customEntryTimeToLive = null;
     Object o1 = regionAttributes.getCustomEntryTimeToLive();
@@ -886,33 +951,43 @@ public class RegionManagementDUnitTest extends ManagementTestBase {
 
     assertThat(regionAttributesData.isIgnoreJTA()).isEqualTo(regionAttributes.getIgnoreJTA());
 
-    assertThat(regionAttributesData.getDataPolicy()).isEqualTo(regionAttributes.getDataPolicy().toString());
+    assertThat(regionAttributesData.getDataPolicy())
+        .isEqualTo(regionAttributes.getDataPolicy().toString());
 
     assertThat(regionAttributesData.getScope()).isEqualTo(regionAttributes.getScope().toString());
 
-    assertThat(regionAttributesData.getInitialCapacity()).isEqualTo(regionAttributes.getInitialCapacity());
+    assertThat(regionAttributesData.getInitialCapacity())
+        .isEqualTo(regionAttributes.getInitialCapacity());
 
     assertThat(regionAttributesData.getLoadFactor()).isEqualTo(regionAttributes.getLoadFactor());
 
     assertThat(regionAttributesData.isLockGrantor()).isEqualTo(regionAttributes.isLockGrantor());
 
-    assertThat(regionAttributesData.isMulticastEnabled()).isEqualTo(regionAttributes.getMulticastEnabled());
+    assertThat(regionAttributesData.isMulticastEnabled())
+        .isEqualTo(regionAttributes.getMulticastEnabled());
 
-    assertThat(regionAttributesData.getConcurrencyLevel()).isEqualTo(regionAttributes.getConcurrencyLevel());
+    assertThat(regionAttributesData.getConcurrencyLevel())
+        .isEqualTo(regionAttributes.getConcurrencyLevel());
 
-    assertThat(regionAttributesData.isIndexMaintenanceSynchronous()).isEqualTo(regionAttributes.getIndexMaintenanceSynchronous());
+    assertThat(regionAttributesData.isIndexMaintenanceSynchronous())
+        .isEqualTo(regionAttributes.getIndexMaintenanceSynchronous());
 
-    assertThat(regionAttributesData.isStatisticsEnabled()).isEqualTo(regionAttributes.getStatisticsEnabled());
+    assertThat(regionAttributesData.isStatisticsEnabled())
+        .isEqualTo(regionAttributes.getStatisticsEnabled());
 
-    assertThat(regionAttributesData.isSubscriptionConflationEnabled()).isEqualTo(regionAttributes.getEnableSubscriptionConflation());
+    assertThat(regionAttributesData.isSubscriptionConflationEnabled())
+        .isEqualTo(regionAttributes.getEnableSubscriptionConflation());
 
-    assertThat(regionAttributesData.isAsyncConflationEnabled()).isEqualTo(regionAttributes.getEnableAsyncConflation());
+    assertThat(regionAttributesData.isAsyncConflationEnabled())
+        .isEqualTo(regionAttributes.getEnableAsyncConflation());
 
     assertThat(regionAttributesData.getPoolName()).isEqualTo(regionAttributes.getPoolName());
 
-    assertThat(regionAttributesData.isCloningEnabled()).isEqualTo(regionAttributes.getCloningEnabled());
+    assertThat(regionAttributesData.isCloningEnabled())
+        .isEqualTo(regionAttributes.getCloningEnabled());
 
-    assertThat(regionAttributesData.getDiskStoreName()).isEqualTo(regionAttributes.getDiskStoreName());
+    assertThat(regionAttributesData.getDiskStoreName())
+        .isEqualTo(regionAttributes.getDiskStoreName());
 
     String interestPolicy = null;
     if (regionAttributes.getSubscriptionAttributes() != null) {
@@ -920,7 +995,8 @@ public class RegionManagementDUnitTest extends ManagementTestBase {
     }
     assertThat(regionAttributesData.getInterestPolicy()).isEqualTo(interestPolicy);
 
-    assertThat(regionAttributesData.isDiskSynchronous()).isEqualTo(regionAttributes.isDiskSynchronous());
+    assertThat(regionAttributesData.isDiskSynchronous())
+        .isEqualTo(regionAttributes.isDiskSynchronous());
   }
 
   private void verifyRemoteFixedPartitionRegion(final VM managerVM) throws Exception {
@@ -938,7 +1014,8 @@ public class RegionManagementDUnitTest extends ManagementTestBase {
         assertThat(fixedPrData).hasSize(3);
 
         for (int i = 0; i < fixedPrData.length; i++) {
-          //LogWriterUtils.getLogWriter().info("<ExpectedString> Remote PR Data is " + fixedPrData[i] + "</ExpectedString> ");
+          // LogWriterUtils.getLogWriter().info("<ExpectedString> Remote PR Data is " +
+          // fixedPrData[i] + "</ExpectedString> ");
         }
       }
     });
@@ -955,7 +1032,8 @@ public class RegionManagementDUnitTest extends ManagementTestBase {
   private void createPartitionRegion_tmp(final VM vm, final String partitionRegionName) {
     vm.invoke("Create Partitioned region", () -> {
       SystemManagementService service = getSystemManagementService_tmp();
-      RegionFactory regionFactory = getCache_tmp().createRegionFactory(RegionShortcut.PARTITION_REDUNDANT);
+      RegionFactory regionFactory =
+          getCache_tmp().createRegionFactory(RegionShortcut.PARTITION_REDUNDANT);
       regionFactory.create(partitionRegionName);
     });
   }
@@ -968,7 +1046,8 @@ public class RegionManagementDUnitTest extends ManagementTestBase {
     });
   }
 
-  private void createSubRegion_tmp(final VM vm, final String parentRegionPath, final String subregionName) {
+  private void createSubRegion_tmp(final VM vm, final String parentRegionPath,
+      final String subregionName) {
     vm.invoke("Create Sub region", () -> {
       SystemManagementService service = getSystemManagementService_tmp();
       Region region = getCache_tmp().getRegion(parentRegionPath);
@@ -977,11 +1056,13 @@ public class RegionManagementDUnitTest extends ManagementTestBase {
   }
 
   private String getDistributedMemberId_tmp(final VM vm) {
-    return vm.invoke("getMemberId", () -> getCache_tmp().getDistributedSystem().getDistributedMember().getId());
+    return vm.invoke("getMemberId",
+        () -> getCache_tmp().getDistributedSystem().getDistributedMember().getId());
   }
 
   private DistributedMember getDistributedMember_tmp(final VM anyVM) {
-    return anyVM.invoke("getDistributedMember_tmp", () -> getCache_tmp().getDistributedSystem().getDistributedMember());
+    return anyVM.invoke("getDistributedMember_tmp",
+        () -> getCache_tmp().getDistributedSystem().getDistributedMember());
   }
 
   private SystemManagementService getSystemManagementService_tmp() {
@@ -989,7 +1070,7 @@ public class RegionManagementDUnitTest extends ManagementTestBase {
   }
 
   private DM getDistributionManager_tmp() {
-    return ((GemFireCacheImpl)getCache_tmp()).getDistributionManager();
+    return ((GemFireCacheImpl) getCache_tmp()).getDistributionManager();
   }
 
   private DistributedMember getDistributedMember_tmp() {
@@ -997,14 +1078,16 @@ public class RegionManagementDUnitTest extends ManagementTestBase {
   }
 
   private Set<DistributedMember> getOtherNormalMembers_tmp() {
-    Set<DistributedMember> allMembers = new HashSet<>(getDistributionManager_tmp().getNormalDistributionManagerIds());
+    Set<DistributedMember> allMembers =
+        new HashSet<>(getDistributionManager_tmp().getNormalDistributionManagerIds());
     allMembers.remove(getDistributedMember_tmp());
     return allMembers;
   }
 
   private void awaitMemberCount(final int expectedCount) {
     DistributedSystemMXBean distributedSystemMXBean = awaitDistributedSystemMXBean();
-    await().until(() -> assertThat(distributedSystemMXBean.getMemberCount()).isEqualTo(expectedCount));
+    await()
+        .until(() -> assertThat(distributedSystemMXBean.getMemberCount()).isEqualTo(expectedCount));
   }
 
   private DistributedRegionMXBean awaitDistributedRegionMXBean(final String name) {
@@ -1015,11 +1098,13 @@ public class RegionManagementDUnitTest extends ManagementTestBase {
     return service.getDistributedRegionMXBean(name);
   }
 
-  private DistributedRegionMXBean awaitDistributedRegionMXBean(final String name, final int memberCount) {
+  private DistributedRegionMXBean awaitDistributedRegionMXBean(final String name,
+      final int memberCount) {
     SystemManagementService service = getSystemManagementService_tmp();
 
     await().until(() -> assertThat(service.getDistributedRegionMXBean(name)).isNotNull());
-    await().until(() -> assertThat(service.getDistributedRegionMXBean(name).getMemberCount()).isEqualTo(memberCount));
+    await().until(() -> assertThat(service.getDistributedRegionMXBean(name).getMemberCount())
+        .isEqualTo(memberCount));
 
     return service.getDistributedRegionMXBean(name);
   }
@@ -1029,7 +1114,8 @@ public class RegionManagementDUnitTest extends ManagementTestBase {
     ObjectName objectName = service.getRegionMBeanName(member, name);
     String alias = "awaiting RegionMXBean proxy for " + member;
 
-    await(alias).until(() -> assertThat(service.getMBeanProxy(objectName, RegionMXBean.class)).isNotNull());
+    await(alias)
+        .until(() -> assertThat(service.getMBeanProxy(objectName, RegionMXBean.class)).isNotNull());
 
     return service.getMBeanProxy(objectName, RegionMXBean.class);
   }
@@ -1037,7 +1123,8 @@ public class RegionManagementDUnitTest extends ManagementTestBase {
   private RegionMXBean awaitRegionMXBeanProxy(final ObjectName objectName) {
     SystemManagementService service = getSystemManagementService_tmp();
 
-    await().until(() -> assertThat(service.getMBeanProxy(objectName, RegionMXBean.class)).isNotNull());
+    await()
+        .until(() -> assertThat(service.getMBeanProxy(objectName, RegionMXBean.class)).isNotNull());
 
     return service.getMBeanProxy(objectName, RegionMXBean.class);
   }
@@ -1047,14 +1134,16 @@ public class RegionManagementDUnitTest extends ManagementTestBase {
     ObjectName objectName = service.getMemberMBeanName(member);
     String alias = "awaiting MemberMXBean proxy for " + member;
 
-    await(alias).until(() -> assertThat(service.getMBeanProxy(objectName, MemberMXBean.class)).isNotNull());
+    await(alias)
+        .until(() -> assertThat(service.getMBeanProxy(objectName, MemberMXBean.class)).isNotNull());
 
     return service.getMBeanProxy(objectName, MemberMXBean.class);
   }
 
   private MemberMXBean awaitMemberMXBeanProxy(final ObjectName objectName) {
     SystemManagementService service = getSystemManagementService_tmp();
-    await().until(() -> assertThat(service.getMBeanProxy(objectName, MemberMXBean.class)).isNotNull());
+    await()
+        .until(() -> assertThat(service.getMBeanProxy(objectName, MemberMXBean.class)).isNotNull());
     return service.getMBeanProxy(objectName, MemberMXBean.class);
   }
 
@@ -1091,13 +1180,14 @@ public class RegionManagementDUnitTest extends ManagementTestBase {
     public void handleNotification(final Notification notification, final Object handback) {
       assertThat(notification).isNotNull();
 
-      assertThat(JMXNotificationType.REGION_CREATED.equals(notification.getType()) ||
-                 JMXNotificationType.REGION_CLOSED.equals(notification.getType())).isTrue();
+      assertThat(JMXNotificationType.REGION_CREATED.equals(notification.getType())
+          || JMXNotificationType.REGION_CLOSED.equals(notification.getType())).isTrue();
 
       notifications.add(notification);
 
       // TODO: add better validation
-      //LogWriterUtils.getLogWriter().info("<ExpectedString> Member Level Notifications" + notification + "</ExpectedString> ");
+      // LogWriterUtils.getLogWriter().info("<ExpectedString> Member Level Notifications" +
+      // notification + "</ExpectedString> ");
     }
   }
 
@@ -1121,7 +1211,8 @@ public class RegionManagementDUnitTest extends ManagementTestBase {
       notifications.add(notification);
 
       // TODO: add something that will be validated
-      //LogWriterUtils.getLogWriter().info("<ExpectedString> Distributed System Notifications" + notification + "</ExpectedString> ");
+      // LogWriterUtils.getLogWriter().info("<ExpectedString> Distributed System Notifications" +
+      // notification + "</ExpectedString> ");
     }
   }
 }

http://git-wip-us.apache.org/repos/asf/geode/blob/d261061e/geode-core/src/test/java/org/apache/geode/management/bean/stats/DistributedSystemStatsDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/org/apache/geode/management/bean/stats/DistributedSystemStatsDUnitTest.java b/geode-core/src/test/java/org/apache/geode/management/bean/stats/DistributedSystemStatsDUnitTest.java
index 92d685a..63cf88f 100644
--- a/geode-core/src/test/java/org/apache/geode/management/bean/stats/DistributedSystemStatsDUnitTest.java
+++ b/geode-core/src/test/java/org/apache/geode/management/bean/stats/DistributedSystemStatsDUnitTest.java
@@ -58,22 +58,26 @@ public class DistributedSystemStatsDUnitTest {
       GemFireCacheImpl cache = GemFireCacheImpl.getInstance();
       assertNotNull(cache);
 
-      SystemManagementService service = (SystemManagementService) ManagementService.getManagementService(cache);
+      SystemManagementService service =
+          (SystemManagementService) ManagementService.getManagementService(cache);
       DistributedSystemMXBean distributedSystemMXBean = service.getDistributedSystemMXBean();
       assertNotNull(distributedSystemMXBean);
 
-      Set<DistributedMember> otherMemberSet = cache.getDistributionManager().getOtherNormalDistributionManagerIds();
+      Set<DistributedMember> otherMemberSet =
+          cache.getDistributionManager().getOtherNormalDistributionManagerIds();
       assertEquals(3, otherMemberSet.size());
 
       for (DistributedMember member : otherMemberSet) {
         ObjectName memberMXBeanName = service.getMemberMBeanName(member);
-        await().atMost(2, TimeUnit.MINUTES).until(() -> assertTrue(ManagementFactory.getPlatformMBeanServer().isRegistered(memberMXBeanName)));
+        await().atMost(2, TimeUnit.MINUTES).until(() -> assertTrue(
+            ManagementFactory.getPlatformMBeanServer().isRegistered(memberMXBeanName)));
 
         MemberMXBean memberMXBean = service.getMBeanProxy(memberMXBeanName, MemberMXBean.class);
         assertNotNull(memberMXBean);
 
         final long lastRefreshTime = service.getLastUpdateTime(memberMXBeanName);
-        await().atMost(1, TimeUnit.MINUTES).until(() -> assertTrue(service.getLastUpdateTime(memberMXBeanName) > lastRefreshTime));
+        await().atMost(1, TimeUnit.MINUTES)
+            .until(() -> assertTrue(service.getLastUpdateTime(memberMXBeanName) > lastRefreshTime));
       }
     });
   }

http://git-wip-us.apache.org/repos/asf/geode/blob/d261061e/geode-core/src/test/java/org/apache/geode/management/internal/beans/QueryDataFunctionApplyLimitClauseTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/org/apache/geode/management/internal/beans/QueryDataFunctionApplyLimitClauseTest.java b/geode-core/src/test/java/org/apache/geode/management/internal/beans/QueryDataFunctionApplyLimitClauseTest.java
index 128280e..dcfd2bf 100644
--- a/geode-core/src/test/java/org/apache/geode/management/internal/beans/QueryDataFunctionApplyLimitClauseTest.java
+++ b/geode-core/src/test/java/org/apache/geode/management/internal/beans/QueryDataFunctionApplyLimitClauseTest.java
@@ -44,7 +44,9 @@ public class QueryDataFunctionApplyLimitClauseTest {
   public void applyLimitClauseDoesNothingIfLimitClauseSpecified() {
     String limitClause = " LIMIT 50";
     String selectQueryWithLimit = selectQuery + limitClause;
-    assertThat(QueryDataFunction.applyLimitClause(selectQueryWithLimit, limit_10, queryResultSetLimit_100)).isEqualTo(selectQueryWithLimit);
+    assertThat(
+        QueryDataFunction.applyLimitClause(selectQueryWithLimit, limit_10, queryResultSetLimit_100))
+            .isEqualTo(selectQueryWithLimit);
   }
 
   @Test
@@ -62,13 +64,16 @@ public class QueryDataFunctionApplyLimitClauseTest {
   @Test // GEODE-1907
   public void applyLimitClauseAddsQueryResultSetLimitIfMissingSpaceAfterFrom() {
     String selectQueryMissingSpaceAfterFrom = "SELECT * FROM/MyRegion";
-    assertThat(QueryDataFunction.applyLimitClause(selectQueryMissingSpaceAfterFrom, limit_0, queryResultSetLimit_100)).isEqualTo(selectQueryMissingSpaceAfterFrom + " LIMIT " + queryResultSetLimit_100);
+    assertThat(QueryDataFunction.applyLimitClause(selectQueryMissingSpaceAfterFrom, limit_0,
+        queryResultSetLimit_100))
+            .isEqualTo(selectQueryMissingSpaceAfterFrom + " LIMIT " + queryResultSetLimit_100);
   }
 
   @Test
   public void applyLimitClauseDoesNotAddQueryResultSetLimitIfMissingSpaceAfterFromButLimitIsPresent() {
     String selectQueryMissingSpaceAfterFromWithLimit = "SELECT * FROM/MyRegion LIMIT " + limit_10;
-    assertThat(QueryDataFunction.applyLimitClause(selectQueryMissingSpaceAfterFromWithLimit, limit_0, queryResultSetLimit_100)).isEqualTo(selectQueryMissingSpaceAfterFromWithLimit);
+    assertThat(QueryDataFunction.applyLimitClause(selectQueryMissingSpaceAfterFromWithLimit,
+        limit_0, queryResultSetLimit_100)).isEqualTo(selectQueryMissingSpaceAfterFromWithLimit);
   }
 
 }

http://git-wip-us.apache.org/repos/asf/geode/blob/d261061e/geode-core/src/test/java/org/apache/geode/management/internal/pulse/TestClientIdsDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/org/apache/geode/management/internal/pulse/TestClientIdsDUnitTest.java b/geode-core/src/test/java/org/apache/geode/management/internal/pulse/TestClientIdsDUnitTest.java
index 3591cb5..a7940a4 100644
--- a/geode-core/src/test/java/org/apache/geode/management/internal/pulse/TestClientIdsDUnitTest.java
+++ b/geode-core/src/test/java/org/apache/geode/management/internal/pulse/TestClientIdsDUnitTest.java
@@ -63,14 +63,15 @@ import org.apache.geode.test.junit.categories.DistributedTest;
  * This is for testing client IDs
  */
 @Category(DistributedTest.class)
-@SuppressWarnings({ "serial", "unused" })
+@SuppressWarnings({"serial", "unused"})
 public class TestClientIdsDUnitTest implements Serializable {
 
   private static final String KEY1 = "KEY1";
   private static final String KEY2 = "KEY2";
   private static final String VALUE1 = "client-KEY1";
   private static final String VALUE2 = "client-KEY2";
-  private static final String REGION_NAME = TestClientIdsDUnitTest.class.getSimpleName() + "_Region";
+  private static final String REGION_NAME =
+      TestClientIdsDUnitTest.class.getSimpleName() + "_Region";
 
   @Manager
   private VM managerVM;
@@ -95,14 +96,16 @@ public class TestClientIdsDUnitTest implements Serializable {
 
     int port = this.serverVM.invoke(() -> createServerCache());
 
-    this.client1VM.invoke(() -> createClientCache(getServerHostName(this.serverVM.getHost()), port));
-    this.client2VM.invoke(() -> createClientCache(getServerHostName(this.serverVM.getHost()), port));
+    this.client1VM
+        .invoke(() -> createClientCache(getServerHostName(this.serverVM.getHost()), port));
+    this.client2VM
+        .invoke(() -> createClientCache(getServerHostName(this.serverVM.getHost()), port));
 
     DistributedMember serverMember = this.managementTestRule.getDistributedMember(this.serverVM);
     DistributedMember client1Member = this.managementTestRule.getDistributedMember(this.client1VM);
     DistributedMember client2Member = this.managementTestRule.getDistributedMember(this.client2VM);
 
-//    this.managerVM.invoke(() -> verifyClientIds(serverMember, port));
+    // this.managerVM.invoke(() -> verifyClientIds(serverMember, port));
     this.managerVM.invoke(() -> {
       CacheServerMXBean cacheServerMXBean = awaitCacheServerMXBean(serverMember, port);
       await().until(() -> {
@@ -136,24 +139,19 @@ public class TestClientIdsDUnitTest implements Serializable {
   private void createClientCache(final String host, final int serverPort) {
     ClientCache cache = this.managementTestRule.getClientCache();
 
-    PoolImpl pool = (PoolImpl) PoolManager.createFactory()
-                                          .addServer(host, serverPort)
-                                          .setSubscriptionEnabled(false)
-                                          .setThreadLocalConnections(true)
-                                          .setMinConnections(1)
-                                          .setReadTimeout(20000)
-                                          .setPingInterval(10000)
-                                          .setRetryAttempts(1)
-                                          .setSubscriptionEnabled(true)
-                                          .setStatisticInterval(1000)
-                                          .create(getClass().getSimpleName());
-
-    ClientRegionFactory factory = cache.createClientRegionFactory(ClientRegionShortcut.CACHING_PROXY);
+    PoolImpl pool = (PoolImpl) PoolManager.createFactory().addServer(host, serverPort)
+        .setSubscriptionEnabled(false).setThreadLocalConnections(true).setMinConnections(1)
+        .setReadTimeout(20000).setPingInterval(10000).setRetryAttempts(1)
+        .setSubscriptionEnabled(true).setStatisticInterval(1000).create(getClass().getSimpleName());
+
+    ClientRegionFactory factory =
+        cache.createClientRegionFactory(ClientRegionShortcut.CACHING_PROXY);
     factory.setPoolName(pool.getName());
     factory.create(REGION_NAME);
   }
 
-  private void verifyClientIds(final DistributedMember serverMember, final int serverPort) throws Exception {
+  private void verifyClientIds(final DistributedMember serverMember, final int serverPort)
+      throws Exception {
     CacheServerMXBean cacheServerMXBean = awaitCacheServerMXBean(serverMember, serverPort);
     await().until(() -> {
       try {
@@ -165,11 +163,13 @@ public class TestClientIdsDUnitTest implements Serializable {
     assertThat(cacheServerMXBean.getClientIds()).hasSize(2); // TODO
   }
 
-  private CacheServerMXBean awaitCacheServerMXBean(final DistributedMember serverMember, final int port) {
+  private CacheServerMXBean awaitCacheServerMXBean(final DistributedMember serverMember,
+      final int port) {
     SystemManagementService service = this.managementTestRule.getSystemManagementService();
     ObjectName objectName = service.getCacheServerMBeanName(port, serverMember);
 
-    await().until(() -> assertThat(service.getMBeanProxy(objectName, CacheServerMXBean.class)).isNotNull());
+    await().until(
+        () -> assertThat(service.getMBeanProxy(objectName, CacheServerMXBean.class)).isNotNull());
 
     return service.getMBeanProxy(objectName, CacheServerMXBean.class);
   }

http://git-wip-us.apache.org/repos/asf/geode/blob/d261061e/geode-core/src/test/java/org/apache/geode/management/internal/pulse/TestSubscriptionsDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/org/apache/geode/management/internal/pulse/TestSubscriptionsDUnitTest.java b/geode-core/src/test/java/org/apache/geode/management/internal/pulse/TestSubscriptionsDUnitTest.java
index f09e7c9..52c7b9c 100644
--- a/geode-core/src/test/java/org/apache/geode/management/internal/pulse/TestSubscriptionsDUnitTest.java
+++ b/geode-core/src/test/java/org/apache/geode/management/internal/pulse/TestSubscriptionsDUnitTest.java
@@ -51,7 +51,8 @@ import org.apache.geode.test.junit.categories.DistributedTest;
 @SuppressWarnings("serial")
 public class TestSubscriptionsDUnitTest extends ManagementTestBase {
 
-  private static final String REGION_NAME = TestSubscriptionsDUnitTest.class.getSimpleName() + "_Region";
+  private static final String REGION_NAME =
+      TestSubscriptionsDUnitTest.class.getSimpleName() + "_Region";
 
   private static final String KEY1 = "k1";
   private static final String KEY2 = "k2";
@@ -137,17 +138,11 @@ public class TestSubscriptionsDUnitTest extends ManagementTestBase {
 
     Cache cache = createCache(props);
 
-    PoolImpl p = (PoolImpl) PoolManager.createFactory()
-                                       .addServer(host, port1)
-                                       .setSubscriptionEnabled(true)
-                                       .setThreadLocalConnections(true)
-                                       .setMinConnections(1)
-                                       .setReadTimeout(20000)
-                                       .setPingInterval(10000)
-                                       .setRetryAttempts(1)
-                                       .setSubscriptionEnabled(true)
-                                       .setStatisticInterval(1000)
-                                       .create("TestSubscriptionsDUnitTest");
+    PoolImpl p =
+        (PoolImpl) PoolManager.createFactory().addServer(host, port1).setSubscriptionEnabled(true)
+            .setThreadLocalConnections(true).setMinConnections(1).setReadTimeout(20000)
+            .setPingInterval(10000).setRetryAttempts(1).setSubscriptionEnabled(true)
+            .setStatisticInterval(1000).create("TestSubscriptionsDUnitTest");
 
     AttributesFactory factory = new AttributesFactory();
     factory.setScope(Scope.DISTRIBUTED_ACK);
@@ -168,15 +163,18 @@ public class TestSubscriptionsDUnitTest extends ManagementTestBase {
         public boolean done() {
           ManagementService service = ManagementService.getExistingManagementService(cache);
           DistributedSystemMXBean distributedSystemMXBean = service.getDistributedSystemMXBean();
-          return distributedSystemMXBean != null & distributedSystemMXBean.getNumSubscriptions() > 1;
+          return distributedSystemMXBean != null
+              & distributedSystemMXBean.getNumSubscriptions() > 1;
         }
+
         @Override
         public String description() {
           return "TestSubscriptionsDUnitTest wait for getDistributedSystemMXBean to complete and get results";
         }
       }, 2 * 60 * 1000, 3000, true);
 
-      DistributedSystemMXBean distributedSystemMXBean = ManagementService.getExistingManagementService(cache).getDistributedSystemMXBean();
+      DistributedSystemMXBean distributedSystemMXBean =
+          ManagementService.getExistingManagementService(cache).getDistributedSystemMXBean();
       assertNotNull(distributedSystemMXBean);
       assertEquals(2, distributedSystemMXBean.getNumSubscriptions());
     });

http://git-wip-us.apache.org/repos/asf/geode/blob/d261061e/geode-core/src/test/java/org/apache/geode/test/dunit/AsyncInvocation.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/org/apache/geode/test/dunit/AsyncInvocation.java b/geode-core/src/test/java/org/apache/geode/test/dunit/AsyncInvocation.java
index 88168af..057454d 100644
--- a/geode-core/src/test/java/org/apache/geode/test/dunit/AsyncInvocation.java
+++ b/geode-core/src/test/java/org/apache/geode/test/dunit/AsyncInvocation.java
@@ -316,16 +316,14 @@ public class AsyncInvocation<V> implements Future<V> {
   }
 
   /**
-   * Waits if necessary for at most the given time for the computation
-   * to complete.
+   * Waits if necessary for at most the given time for the computation to complete.
    *
-   * @param  timeout the maximum time to wait
-   * @param  unit the time unit of the timeout argument
+   * @param timeout the maximum time to wait
+   * @param unit the time unit of the timeout argument
    *
    * @return this {@code AsyncInvocation}
    *
-   * @throws AssertionError wrapping any {@code Exception} thrown by this
-   *         {@code AsyncInvocation}.
+   * @throws AssertionError wrapping any {@code Exception} thrown by this {@code AsyncInvocation}.
    *
    * @throws CancellationException if the computation was cancelled
    *
@@ -335,7 +333,8 @@ public class AsyncInvocation<V> implements Future<V> {
    *
    * @throws TimeoutException if the wait timed out
    */
-  public AsyncInvocation<V> await(final long timeout, final TimeUnit unit) throws ExecutionException, InterruptedException, TimeoutException {
+  public AsyncInvocation<V> await(final long timeout, final TimeUnit unit)
+      throws ExecutionException, InterruptedException, TimeoutException {
     long millis = unit.toMillis(timeout);
     join(millis);
     timeoutIfAlive(millis);
@@ -344,17 +343,15 @@ public class AsyncInvocation<V> implements Future<V> {
   }
 
   /**
-   * Waits if necessary for at most the given time for the computation
-   * to complete.
+   * Waits if necessary for at most the given time for the computation to complete.
    *
    * @return this {@code AsyncInvocation}
    *
-   * @throws AssertionError wrapping any {@code Exception} thrown by this
-   *         {@code AsyncInvocation}.
+   * @throws AssertionError wrapping any {@code Exception} thrown by this {@code AsyncInvocation}.
    *
-   * @throws AssertionError wrapping a {@code TimeoutException} if this
-   *         {@code AsyncInvocation} fails to complete within the default
-   *         timeout of 60 seconds as defined by {@link #DEFAULT_JOIN_MILLIS}.
+   * @throws AssertionError wrapping a {@code TimeoutException} if this {@code AsyncInvocation}
+   *         fails to complete within the default timeout of 60 seconds as defined by
+   *         {@link #DEFAULT_JOIN_MILLIS}.
    *
    * @throws CancellationException if the computation was cancelled
    *
@@ -371,8 +368,8 @@ public class AsyncInvocation<V> implements Future<V> {
   }
 
   /**
-   * Waits if necessary for the work to complete, and then returns the result
-   * of this {@code AsyncInvocation}.
+   * Waits if necessary for the work to complete, and then returns the result of this
+   * {@code AsyncInvocation}.
    *
    * @return the result of this {@code AsyncInvocation}
    *

http://git-wip-us.apache.org/repos/asf/geode/blob/d261061e/geode-core/src/test/java/org/apache/geode/test/dunit/VM.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/org/apache/geode/test/dunit/VM.java b/geode-core/src/test/java/org/apache/geode/test/dunit/VM.java
index 375deed..9a42caa 100644
--- a/geode-core/src/test/java/org/apache/geode/test/dunit/VM.java
+++ b/geode-core/src/test/java/org/apache/geode/test/dunit/VM.java
@@ -92,11 +92,11 @@ public class VM implements Serializable {
    * Returns the process id of this {@code VM}.
    */
   public int getPid() {
-//    try {
-      return invoke(() -> ProcessUtils.identifyPid());
-//    } catch (PidUnavailableException e) {
-//      return this.pid;
-//    }
+    // try {
+    return invoke(() -> ProcessUtils.identifyPid());
+    // } catch (PidUnavailableException e) {
+    // return this.pid;
+    // }
   }
 
   /**

http://git-wip-us.apache.org/repos/asf/geode/blob/d261061e/geode-core/src/test/java/org/apache/geode/test/dunit/rules/DistributedRule.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/org/apache/geode/test/dunit/rules/DistributedRule.java b/geode-core/src/test/java/org/apache/geode/test/dunit/rules/DistributedRule.java
index 5ab479b..8e89bdb 100644
--- a/geode-core/src/test/java/org/apache/geode/test/dunit/rules/DistributedRule.java
+++ b/geode-core/src/test/java/org/apache/geode/test/dunit/rules/DistributedRule.java
@@ -1,18 +1,16 @@
 /*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
+ * Licensed to the Apache Software Foundation (ASF) under one or more contributor license
+ * agreements. See the NOTICE file distributed with this work for additional information regarding
+ * copyright ownership. The ASF licenses this file to You under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance with the License. You may obtain a
+ * copy of the License at
  *
- *      http://www.apache.org/licenses/LICENSE-2.0
+ * http://www.apache.org/licenses/LICENSE-2.0
  *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
+ * Unless required by applicable law or agreed to in writing, software distributed under the License
+ * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
+ * or implied. See the License for the specific language governing permissions and limitations under
+ * the License.
  */
 package org.apache.geode.test.dunit.rules;
 
@@ -24,21 +22,21 @@ import java.lang.annotation.Target;
 import org.junit.Rule;
 
 /**
- * Annotates a field or method as a type of {@link Rule} that can be invoked
- * across multiple VMs in a {@code DistributedTest}.
+ * Annotates a field or method as a type of {@link Rule} that can be invoked across multiple VMs in
+ * a {@code DistributedTest}.
  *
- * If there are multiple annotated {@code DistributedRule}s on a class, they
- * will be applied in order of fields first, then methods. Furthermore, if
- * there are multiple fields (or methods) they will be applied in an order that
- * depends on your JVM's implementation of the reflection API, which is
- * undefined. Rules defined by fields will always be applied before Rules
- * defined by methods. You can use a {@link org.junit.rules.RuleChain} or
- * {@link org.apache.geode.test.junit.rules.RuleList} if you want to have
- * control over the order in which the Rules are applied.
+ * If there are multiple annotated {@code DistributedRule}s on a class, they will be applied in
+ * order of fields first, then methods. Furthermore, if there are multiple fields (or methods) they
+ * will be applied in an order that depends on your JVM's implementation of the reflection API,
+ * which is undefined. Rules defined by fields will always be applied before Rules defined by
+ * methods. You can use a {@link org.junit.rules.RuleChain} or
+ * {@link org.apache.geode.test.junit.rules.RuleList} if you want to have control over the order in
+ * which the Rules are applied.
  *
  * <p>
- * For example, here is a test class that makes a unique
- * {@link org.junit.rules.TemporaryFolder} available to each DUnit VM:
+ * For example, here is a test class that makes a unique {@link org.junit.rules.TemporaryFolder}
+ * available to each DUnit VM:
+ * 
  * <pre>
  * {@literal @}Category(DistributedTest.class)
  * public class EachVMHasItsOwnTemporaryFolder {

http://git-wip-us.apache.org/repos/asf/geode/blob/d261061e/geode-core/src/test/java/org/apache/geode/test/dunit/rules/DistributedRunRules.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/org/apache/geode/test/dunit/rules/DistributedRunRules.java b/geode-core/src/test/java/org/apache/geode/test/dunit/rules/DistributedRunRules.java
index 7490acd..7a86613 100644
--- a/geode-core/src/test/java/org/apache/geode/test/dunit/rules/DistributedRunRules.java
+++ b/geode-core/src/test/java/org/apache/geode/test/dunit/rules/DistributedRunRules.java
@@ -1,18 +1,16 @@
 /*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
+ * Licensed to the Apache Software Foundation (ASF) under one or more contributor license
+ * agreements. See the NOTICE file distributed with this work for additional information regarding
+ * copyright ownership. The ASF licenses this file to You under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance with the License. You may obtain a
+ * copy of the License at
  *
- *      http://www.apache.org/licenses/LICENSE-2.0
+ * http://www.apache.org/licenses/LICENSE-2.0
  *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
+ * Unless required by applicable law or agreed to in writing, software distributed under the License
+ * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
+ * or implied. See the License for the specific language governing permissions and limitations under
+ * the License.
  */
 package org.apache.geode.test.dunit.rules;
 
@@ -32,7 +30,8 @@ public class DistributedRunRules extends Statement implements Serializable {
   private final Statement statement;
   private final WhichVMs whichVMs;
 
-  public DistributedRunRules(final Statement base, final Iterable<TestRule> rules, final Description description, final WhichVMs whichVMs) {
+  public DistributedRunRules(final Statement base, final Iterable<TestRule> rules,
+      final Description description, final WhichVMs whichVMs) {
     this.statement = applyAll(base, rules, description);
     this.whichVMs = whichVMs;
   }
@@ -52,7 +51,8 @@ public class DistributedRunRules extends Statement implements Serializable {
     }
   }
 
-  private Statement applyAll(Statement result, final Iterable<TestRule> rules, final Description description) {
+  private Statement applyAll(Statement result, final Iterable<TestRule> rules,
+      final Description description) {
     for (TestRule each : rules) {
       result = each.apply(result, description);
     }

http://git-wip-us.apache.org/repos/asf/geode/blob/d261061e/geode-core/src/test/java/org/apache/geode/test/dunit/rules/DistributedStatement.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/org/apache/geode/test/dunit/rules/DistributedStatement.java b/geode-core/src/test/java/org/apache/geode/test/dunit/rules/DistributedStatement.java
index 1c78d00..cdc8dda 100644
--- a/geode-core/src/test/java/org/apache/geode/test/dunit/rules/DistributedStatement.java
+++ b/geode-core/src/test/java/org/apache/geode/test/dunit/rules/DistributedStatement.java
@@ -1,18 +1,16 @@
 /*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
+ * Licensed to the Apache Software Foundation (ASF) under one or more contributor license
+ * agreements. See the NOTICE file distributed with this work for additional information regarding
+ * copyright ownership. The ASF licenses this file to You under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance with the License. You may obtain a
+ * copy of the License at
  *
- *      http://www.apache.org/licenses/LICENSE-2.0
+ * http://www.apache.org/licenses/LICENSE-2.0
  *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
+ * Unless required by applicable law or agreed to in writing, software distributed under the License
+ * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
+ * or implied. See the License for the specific language governing permissions and limitations under
+ * the License.
  */
 package org.apache.geode.test.dunit.rules;
 
@@ -33,6 +31,7 @@ public class DistributedStatement extends SerializableStatement {
 
   /**
    * Construct a new {@code DistributedStatement} statement.
+   * 
    * @param next the next {@code Statement} in the execution chain
    * @param whichVMs specifies which VMs should invoke the statement
    */

http://git-wip-us.apache.org/repos/asf/geode/blob/d261061e/geode-core/src/test/java/org/apache/geode/test/dunit/rules/DistributedTestRule.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/org/apache/geode/test/dunit/rules/DistributedTestRule.java b/geode-core/src/test/java/org/apache/geode/test/dunit/rules/DistributedTestRule.java
index 9516cb3..31fba3d 100644
--- a/geode-core/src/test/java/org/apache/geode/test/dunit/rules/DistributedTestRule.java
+++ b/geode-core/src/test/java/org/apache/geode/test/dunit/rules/DistributedTestRule.java
@@ -1,18 +1,16 @@
 /*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
+ * Licensed to the Apache Software Foundation (ASF) under one or more contributor license
+ * agreements. See the NOTICE file distributed with this work for additional information regarding
+ * copyright ownership. The ASF licenses this file to You under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance with the License. You may obtain a
+ * copy of the License at
  *
- *      http://www.apache.org/licenses/LICENSE-2.0
+ * http://www.apache.org/licenses/LICENSE-2.0
  *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
+ * Unless required by applicable law or agreed to in writing, software distributed under the License
+ * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
+ * or implied. See the License for the specific language governing permissions and limitations under
+ * the License.
  */
 package org.apache.geode.test.dunit.rules;
 
@@ -32,7 +30,8 @@ import org.apache.geode.test.dunit.standalone.DUnitLauncher;
 /**
  * Launches the DUnit framework for a {@code DistributedTest}.
  *
- * <p>Enables use of {@link DistributedRule} annotations on any Rules.
+ * <p>
+ * Enables use of {@link DistributedRule} annotations on any Rules.
  *
  * <pre>
  * {@literal @}Category(DistributedTest.class)
@@ -47,10 +46,10 @@ import org.apache.geode.test.dunit.standalone.DUnitLauncher;
  *   ...
  * }
  * </pre>
- * <p>Use the {@code Builder} to specify which {@code VM}s should invoke any
- * {@code Rule} annotated with {@literal @}DistributedRule. By default,
- * {@code controllerVM} is {@code true}, {@code everyVM} is {@code true} and
- * {@code locatorVM} is {@code false}.
+ * <p>
+ * Use the {@code Builder} to specify which {@code VM}s should invoke any {@code Rule} annotated
+ * with {@literal @}DistributedRule. By default, {@code controllerVM} is {@code true},
+ * {@code everyVM} is {@code true} and {@code locatorVM} is {@code false}.
  */
 public class DistributedTestRule implements MethodRule, Serializable {
 
@@ -96,7 +95,8 @@ public class DistributedTestRule implements MethodRule, Serializable {
     return statement;
   }
 
-  protected Statement withDUnit(final FrameworkMethod method, final Object target, final Statement statement) {
+  protected Statement withDUnit(final FrameworkMethod method, final Object target,
+      final Statement statement) {
     return new Statement() {
       @Override
       public void evaluate() throws Throwable {
@@ -115,50 +115,59 @@ public class DistributedTestRule implements MethodRule, Serializable {
     // TODO: customize based on fields
   }
 
-  protected void tearDownDUnit() throws Exception {
-  }
+  protected void tearDownDUnit() throws Exception {}
 
-  protected Statement withRules(final FrameworkMethod method, final Object target, final Statement statement) {
+  protected Statement withRules(final FrameworkMethod method, final Object target,
+      final Statement statement) {
     List<TestRule> testRules = this.testRules(target);
     Statement result = statement;
-//    result = withMethodRules(method, testRules, target, result);
+    // result = withMethodRules(method, testRules, target, result);
     result = withTestRules(method, testRules, result);
 
     return result;
   }
 
-//  protected Statement withMethodRules(final FrameworkMethod method, final List<TestRule> testRules, final Object target, final Statement result) {
-//    Statement statement = result;
-//    for (MethodRule rule : methodRules(target)) {
-//      if (!testRules.contains(rule)) {
-//        statement = new DistributedStatement(rule.apply((result, method, target), this.whichVMs);
-//      }
-//    }
-//    return statement;
-//  }
-
-  protected Statement withTestRules(final FrameworkMethod method, final List<TestRule> testRules, final Statement statement) {
-    Description description = Description.createTestDescription(this.testClass.getJavaClass(), method.getName(), method.getAnnotations());
-    return testRules.isEmpty() ? statement : new DistributedRunRules(statement, testRules, description, this.whichVMs);
+  // protected Statement withMethodRules(final FrameworkMethod method, final List<TestRule>
+  // testRules, final Object target, final Statement result) {
+  // Statement statement = result;
+  // for (MethodRule rule : methodRules(target)) {
+  // if (!testRules.contains(rule)) {
+  // statement = new DistributedStatement(rule.apply((result, method, target), this.whichVMs);
+  // }
+  // }
+  // return statement;
+  // }
+
+  protected Statement withTestRules(final FrameworkMethod method, final List<TestRule> testRules,
+      final Statement statement) {
+    Description description = Description.createTestDescription(this.testClass.getJavaClass(),
+        method.getName(), method.getAnnotations());
+    return testRules.isEmpty() ? statement
+        : new DistributedRunRules(statement, testRules, description, this.whichVMs);
   }
 
   protected List<MethodRule> methodRules(final Object target) {
-    List<MethodRule> rules = this.testClass.getAnnotatedMethodValues(target, DistributedRule.class, MethodRule.class);
-    rules.addAll(this.testClass.getAnnotatedFieldValues(target, DistributedRule.class, MethodRule.class));
+    List<MethodRule> rules =
+        this.testClass.getAnnotatedMethodValues(target, DistributedRule.class, MethodRule.class);
+    rules.addAll(
+        this.testClass.getAnnotatedFieldValues(target, DistributedRule.class, MethodRule.class));
     return rules;
   }
 
   protected List<TestRule> testRules(final Object target) {
-    List<TestRule> result = this.testClass.getAnnotatedMethodValues(target, DistributedRule.class, TestRule.class);
-    result.addAll(this.testClass.getAnnotatedFieldValues(target, DistributedRule.class, TestRule.class));
+    List<TestRule> result =
+        this.testClass.getAnnotatedMethodValues(target, DistributedRule.class, TestRule.class);
+    result.addAll(
+        this.testClass.getAnnotatedFieldValues(target, DistributedRule.class, TestRule.class));
     return result;
   }
 
   /**
    * Builds an instance of {@link DistributedTestRule}.
    *
-   * <p>By default, {@code controllerVM} is {@code true}, {@code everyVM} is
-   * {@code true} and {@code locatorVM} is {@code false}.
+   * <p>
+   * By default, {@code controllerVM} is {@code true}, {@code everyVM} is {@code true} and
+   * {@code locatorVM} is {@code false}.
    */
   public static class Builder {
 
@@ -166,8 +175,7 @@ public class DistributedTestRule implements MethodRule, Serializable {
     private boolean locatorVM = false;
     private boolean controllerVM = true;
 
-    protected Builder() {
-    }
+    protected Builder() {}
 
     public Builder everyVM(final boolean everyVM) {
       this.everyVM = everyVM;

http://git-wip-us.apache.org/repos/asf/geode/blob/d261061e/geode-core/src/test/java/org/apache/geode/test/dunit/rules/DistributedUseJacksonForJsonPathRule.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/org/apache/geode/test/dunit/rules/DistributedUseJacksonForJsonPathRule.java b/geode-core/src/test/java/org/apache/geode/test/dunit/rules/DistributedUseJacksonForJsonPathRule.java
index 78841fc..8c85775 100644
--- a/geode-core/src/test/java/org/apache/geode/test/dunit/rules/DistributedUseJacksonForJsonPathRule.java
+++ b/geode-core/src/test/java/org/apache/geode/test/dunit/rules/DistributedUseJacksonForJsonPathRule.java
@@ -1,18 +1,16 @@
 /*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
+ * Licensed to the Apache Software Foundation (ASF) under one or more contributor license
+ * agreements. See the NOTICE file distributed with this work for additional information regarding
+ * copyright ownership. The ASF licenses this file to You under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance with the License. You may obtain a
+ * copy of the License at
  *
- *      http://www.apache.org/licenses/LICENSE-2.0
+ * http://www.apache.org/licenses/LICENSE-2.0
  *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
+ * Unless required by applicable law or agreed to in writing, software distributed under the License
+ * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
+ * or implied. See the License for the specific language governing permissions and limitations under
+ * the License.
  */
 package org.apache.geode.test.dunit.rules;
 
@@ -45,6 +43,7 @@ public class DistributedUseJacksonForJsonPathRule extends UseJacksonForJsonPathR
   private static void invokeBefore() {
     instance.before();
   }
+
   private static void invokeAfter() {
     instance.after();
   }

http://git-wip-us.apache.org/repos/asf/geode/blob/d261061e/geode-core/src/test/java/org/apache/geode/test/dunit/rules/DistributedWrapperRule.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/org/apache/geode/test/dunit/rules/DistributedWrapperRule.java b/geode-core/src/test/java/org/apache/geode/test/dunit/rules/DistributedWrapperRule.java
index 45311e1..6b1f8f1 100644
--- a/geode-core/src/test/java/org/apache/geode/test/dunit/rules/DistributedWrapperRule.java
+++ b/geode-core/src/test/java/org/apache/geode/test/dunit/rules/DistributedWrapperRule.java
@@ -1,18 +1,16 @@
 /*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
+ * Licensed to the Apache Software Foundation (ASF) under one or more contributor license
+ * agreements. See the NOTICE file distributed with this work for additional information regarding
+ * copyright ownership. The ASF licenses this file to You under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance with the License. You may obtain a
+ * copy of the License at
  *
- *      http://www.apache.org/licenses/LICENSE-2.0
+ * http://www.apache.org/licenses/LICENSE-2.0
  *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
+ * Unless required by applicable law or agreed to in writing, software distributed under the License
+ * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
+ * or implied. See the License for the specific language governing permissions and limitations under
+ * the License.
  */
 package org.apache.geode.test.dunit.rules;
 
@@ -39,14 +37,15 @@ public class DistributedWrapperRule implements SerializableTestRule {
     this(new RemoteInvoker(), testRule, whichVMs);
   }
 
-  public DistributedWrapperRule(final RemoteInvoker invoker, final SerializableTestRule testRule, final WhichVMs whichVMs) {
+  public DistributedWrapperRule(final RemoteInvoker invoker, final SerializableTestRule testRule,
+      final WhichVMs whichVMs) {
     this.invoker = invoker;
     instance = testRule;
     this.whichVMs = whichVMs;
   }
 
   @Override
-  public Statement apply(Statement base, Description description){
+  public Statement apply(Statement base, Description description) {
     return new DistributedStatement((SerializableStatement) base, whichVMs);
   }
 }


Mime
View raw message