Merge pull request hazelcast#628 from hazelcast/update-cp-samples-to-ee

Updated CP samples to EE [HZ-4480]
- changed terminate() method on shutdown() to prevent last member hanging issue

cp-subsystem/cp-atomiclong/src/main/java/com/hazelcast/codesamples/cp/atomiclong/CPMember.java

@@ -5,13 +5,17 @@
 import com.hazelcast.core.HazelcastInstance;
 import com.hazelcast.cp.IAtomicLong;
 
+import static com.hazelcast.examples.helper.LicenseUtils.ENTERPRISE_LICENSE_KEY;
 import static java.util.concurrent.TimeUnit.SECONDS;
 
 /**
  * Configures a CP subsystem of 3 CP members. When you run 3 instances of this
  * class, it will form the CP subsystem. Then, it fetches
  * a CP {@link IAtomicLong} proxy and increments the counter value
  * {@link #NUMBER_OF_INCREMENTS} times.
+ *
+ * You have to set your Hazelcast Enterprise license key to make this code sample work.
+ * Please have a look at {@link com.hazelcast.examples.helper.LicenseUtils} for details.
  */
 public class CPMember {
 
@@ -20,6 +24,7 @@ public class CPMember {
 
     public static void main(String[] args) throws InterruptedException {
         Config config = new Config();
+        config.setLicenseKey(ENTERPRISE_LICENSE_KEY);
         config.getCPSubsystemConfig().setCPMemberCount(CP_MEMBER_COUNT);
         HazelcastInstance hz = Hazelcast.newHazelcastInstance(config);
         IAtomicLong counter = hz.getCPSubsystem().getAtomicLong("counter");
@@ -43,6 +48,6 @@ public static void main(String[] args) throws InterruptedException {
         // always destroy CP Subsystem data structures otherwise it can lead to a memory leak
         counter.destroy();
 
-        hz.getLifecycleService().terminate();
+        hz.shutdown();
     }
 }

cp-subsystem/cp-atomicreference/src/main/java/com/hazelcast/codesamples/cp/atomicreference/CPMember.java

@@ -5,13 +5,17 @@
 import com.hazelcast.core.HazelcastInstance;
 import com.hazelcast.cp.IAtomicReference;
 
+import static com.hazelcast.examples.helper.LicenseUtils.ENTERPRISE_LICENSE_KEY;
 import static java.util.concurrent.TimeUnit.SECONDS;
 
 /**
  * Configures a CP subsystem of 3 CP members. When you run 3 instances of this
  * class, it will form the CP subsystem. Then, it fetches
  * a CP {@link IAtomicReference} proxy and increments the integer value with
  * CAS {@link #NUMBER_OF_INCREMENTS} times.
+ *
+ * You have to set your Hazelcast Enterprise license key to make this code sample work.
+ * Please have a look at {@link com.hazelcast.examples.helper.LicenseUtils} for details.
  */
 public class CPMember {
 
@@ -20,6 +24,7 @@ public class CPMember {
 
     public static void main(String[] args) throws InterruptedException {
         Config config = new Config();
+        config.setLicenseKey(ENTERPRISE_LICENSE_KEY);
         config.getCPSubsystemConfig().setCPMemberCount(CP_MEMBER_COUNT);
         HazelcastInstance hz = Hazelcast.newHazelcastInstance(config);
         IAtomicReference<Integer> ref = hz.getCPSubsystem().getAtomicReference("reference");
@@ -47,6 +52,6 @@ public static void main(String[] args) throws InterruptedException {
         // always destroy CP Subsystem data structures otherwise it can lead to a memory leak
         ref.destroy();
 
-        hz.getLifecycleService().terminate();
+        hz.shutdown();
     }
 }

cp-subsystem/cp-countdownlatch/src/main/java/com/hazelcast/codesamples/cp/countdownlatch/CPMember.java

@@ -5,6 +5,7 @@
 import com.hazelcast.core.HazelcastInstance;
 import com.hazelcast.cp.ICountDownLatch;
 
+import static com.hazelcast.examples.helper.LicenseUtils.ENTERPRISE_LICENSE_KEY;
 import static java.util.concurrent.TimeUnit.SECONDS;
 
 /**
@@ -13,13 +14,17 @@
  * a CP {@link ICountDownLatch} proxy. Each CP member performs some dummy work
  * and decrements the count value. After that, it waits for all CP members to
  * complete their work.
+ *
+ * You have to set your Hazelcast Enterprise license key to make this code sample work.
+ * Please have a look at {@link com.hazelcast.examples.helper.LicenseUtils} for details.
  */
 public class CPMember {
 
     private static final int CP_MEMBER_COUNT = 3;
 
     public static void main(String[] args) throws Exception {
         Config config = new Config();
+        config.setLicenseKey(ENTERPRISE_LICENSE_KEY);
         config.getCPSubsystemConfig().setCPMemberCount(CP_MEMBER_COUNT);
         HazelcastInstance hz = Hazelcast.newHazelcastInstance(config);
         ICountDownLatch latch = hz.getCPSubsystem().getCountDownLatch("latch");
@@ -51,6 +56,6 @@ public static void main(String[] args) throws Exception {
         // always destroy CP Subsystem data structures otherwise it can lead to a memory leak
         latch.destroy();
 
-        hz.getLifecycleService().terminate();
+        hz.shutdown();
     }
 }

cp-subsystem/cp-listeners/src/main/java/com/hazelcast/codesamples/cp/groupavailabilitylistener/CPMember.java

@@ -4,6 +4,8 @@
 import com.hazelcast.core.Hazelcast;
 import com.hazelcast.core.HazelcastInstance;
 
+import static com.hazelcast.examples.helper.LicenseUtils.ENTERPRISE_LICENSE_KEY;
+
 /**
  * Configures a CP subsystem of 3 CP members. When you run 3 instances of this
  * class, it will form the CP subsystem.
@@ -13,13 +15,17 @@
  * <p>
  * If you terminate one more process, after some time the remaining member
  * will print CP group majority lost event to the console.
+ *
+ * You have to set your Hazelcast Enterprise license key to make this code sample work.
+ * Please have a look at {@link com.hazelcast.examples.helper.LicenseUtils} for details.
  */
 public class CPMember {
 
     private static final int CP_MEMBER_COUNT = 3;
 
     public static void main(String[] args) {
         Config config = new Config();
+        config.setLicenseKey(ENTERPRISE_LICENSE_KEY);
         config.getCPSubsystemConfig().setCPMemberCount(CP_MEMBER_COUNT);
 
         HazelcastInstance hz = Hazelcast.newHazelcastInstance(config);

cp-subsystem/cp-listeners/src/main/java/com/hazelcast/codesamples/cp/membershiplistener/CPMember.java

@@ -4,6 +4,8 @@
 import com.hazelcast.core.Hazelcast;
 import com.hazelcast.core.HazelcastInstance;
 
+import static com.hazelcast.examples.helper.LicenseUtils.ENTERPRISE_LICENSE_KEY;
+
 /**
  * Configures a CP subsystem of 3 CP members. When you run 3 instances of this
  * class, it will form the CP subsystem. After leader election is completed
@@ -12,6 +14,9 @@
  * If you terminate one of the processes, after some time that CP member will be
  * automatically removed from CP subsystem and remaining members will print
  * the removed CP member to the console.
+ *
+ * You have to set your Hazelcast Enterprise license key to make this code sample work.
+ * Please have a look at {@link com.hazelcast.examples.helper.LicenseUtils} for details.
  */
 public class CPMember {
 
@@ -20,6 +25,7 @@ public class CPMember {
 
     public static void main(String[] args) {
         Config config = new Config();
+        config.setLicenseKey(ENTERPRISE_LICENSE_KEY);
         config.getCPSubsystemConfig()
                 .setCPMemberCount(CP_MEMBER_COUNT)
                 .setSessionTimeToLiveSeconds(AUTO_REMOVE_MISSING_MEMBER_SEC)

enterprise/cp-map/pom.xml → cp-subsystem/cp-map/pom.xml

@@ -4,15 +4,15 @@
     <packaging>jar</packaging>
 
     <artifactId>cp-map</artifactId>
-    <name>Enterprise - CP Subsystem CPMap</name>
+    <name>Enterprise Advanced - CP Subsystem CPMap</name>
 
     <description>
-        Enterprise - CP Subsystem CPMap
+        Enterprise Advanced - CP Subsystem CPMap
     </description>
 
     <parent>
-        <groupId>com.hazelcast.samples.enterprise</groupId>
-        <artifactId>enterprise</artifactId>
+        <groupId>com.hazelcast.samples.cp</groupId>
+        <artifactId>cp-subsystem</artifactId>
         <version>0.1-SNAPSHOT</version>
         <relativePath>../pom.xml</relativePath>
     </parent>

enterprise/cp-map/src/main/java/com/hazelcast/codesamples/cp/cpmap/CPMember.java → cp-subsystem/cp-map/src/main/java/com/hazelcast/codesamples/cp/cpmap/CPMember.java

@@ -5,13 +5,17 @@
 import com.hazelcast.core.HazelcastInstance;
 import com.hazelcast.cp.CPMap;
 
+import static com.hazelcast.examples.helper.LicenseUtils.ENTERPRISE_LICENSE_KEY;
 import static java.util.concurrent.TimeUnit.SECONDS;
 
 /**
  * Configures a CP subsystem of 3 CP members. When you run 3 instances of this
  * class, it will form the CP subsystem. Then, it fetches
  * a CP {@link CPMap} proxy and increments the integer value with
  * CAS {@link #NUMBER_OF_INCREMENTS} times.
+ *
+ * You have to set your Hazelcast Enterprise license key to make this code sample work.
+ * Please have a look at {@link com.hazelcast.examples.helper.LicenseUtils} for details.
  */
 public class CPMember {
 
@@ -20,6 +24,7 @@ public class CPMember {
 
     public static void main(String[] args) throws InterruptedException {
         Config config = new Config();
+        config.setLicenseKey(ENTERPRISE_LICENSE_KEY);
         config.getCPSubsystemConfig().setCPMemberCount(CP_MEMBER_COUNT);
         HazelcastInstance hz = Hazelcast.newHazelcastInstance(config);
         CPMap<String, Integer> cpMap = hz.getCPSubsystem().getMap("cp-map");
@@ -55,6 +60,6 @@ public static void main(String[] args) throws InterruptedException {
         // always destroy CP Subsystem data structures otherwise it can lead to a memory leak
         cpMap.destroy();
 
-        hz.getLifecycleService().terminate();
+        hz.shutdown();
     }
 }

cp-subsystem/cp-semaphore/src/main/java/com/hazelcast/codesamples/cp/semaphore/CPMember.java

@@ -8,6 +8,7 @@
 import java.util.Date;
 import java.util.Random;
 
+import static com.hazelcast.examples.helper.LicenseUtils.ENTERPRISE_LICENSE_KEY;
 import static java.util.concurrent.TimeUnit.SECONDS;
 
 /**
@@ -18,6 +19,9 @@
  * {@link #NUMBER_OF_ROUNDS} times. At any time, {@code CP_MEMBER_COUNT - 1}
  * CP members will be holding a permit and the last member will be waiting for
  * one of them to release a permit.
+ *
+ * You have to set your Hazelcast Enterprise license key to make this code sample work.
+ * Please have a look at {@link com.hazelcast.examples.helper.LicenseUtils} for details.
  */
 public class CPMember {
 
@@ -26,6 +30,7 @@ public class CPMember {
 
     public static void main(String[] args) throws Exception {
         Config config = new Config();
+        config.setLicenseKey(ENTERPRISE_LICENSE_KEY);
         config.getCPSubsystemConfig().setCPMemberCount(CP_MEMBER_COUNT);
         HazelcastInstance hz = Hazelcast.newHazelcastInstance(config);
         ISemaphore semaphore = hz.getCPSubsystem().getSemaphore("semaphore");
@@ -51,7 +56,7 @@ public static void main(String[] args) throws Exception {
         // always destroy CP Subsystem data structures otherwise it can lead to a memory leak
         semaphore.destroy();
 
-        hz.getLifecycleService().terminate();
+        hz.shutdown();
 
     }
 }

cp-subsystem/fenced-lock-auto-release-on-session-close/src/main/java/com/hazelcast/codesamples/cp/fencedlock/AutoReleaseFencedLockOnSessionClose.java

@@ -8,14 +8,20 @@
 
 import java.util.concurrent.TimeUnit;
 
+import static com.hazelcast.examples.helper.LicenseUtils.ENTERPRISE_LICENSE_KEY;
+
 /**
  * This code sample demonstrates that a FencedLock is eventually released when
  * its holder does not commit CP session heartbeats.
+ *
+ * You have to set your Hazelcast Enterprise license key to make this code sample work.
+ * Please have a look at {@link com.hazelcast.examples.helper.LicenseUtils} for details.
  */
 public class AutoReleaseFencedLockOnSessionClose {
 
     public static void main(String[] args) throws InterruptedException {
         Config config = new Config();
+        config.setLicenseKey(ENTERPRISE_LICENSE_KEY);
         CPSubsystemConfig cpSubsystemConfig = config.getCPSubsystemConfig();
         cpSubsystemConfig.setCPMemberCount(3);
         cpSubsystemConfig.setSessionHeartbeatIntervalSeconds(1);

cp-subsystem/fenced-lock-auto-release-on-shutdown/src/main/java/com/hazelcast/codesamples/cp/fencedlock/AutoReleaseFencedLockOnShutdown.java

@@ -6,14 +6,20 @@
 import com.hazelcast.core.HazelcastInstance;
 import com.hazelcast.cp.lock.FencedLock;
 
+import static com.hazelcast.examples.helper.LicenseUtils.ENTERPRISE_LICENSE_KEY;
+
 /**
  * This code sample demonstrates that a Hazelcast instance releases the lock
  * instances it holds during shutdown.
+ *
+ * You have to set your Hazelcast Enterprise license key to make this code sample work.
+ * Please have a look at {@link com.hazelcast.examples.helper.LicenseUtils} for details.
  */
 public class AutoReleaseFencedLockOnShutdown {
 
     public static void main(String[] args) {
         Config config = new Config();
+        config.setLicenseKey(ENTERPRISE_LICENSE_KEY);
         CPSubsystemConfig cpSubsystemConfig = config.getCPSubsystemConfig();
         cpSubsystemConfig.setCPMemberCount(3);
         HazelcastInstance hz1 = Hazelcast.newHazelcastInstance(config);

cp-subsystem/fenced-lock-basic-usage/src/main/java/com/hazelcast/codesamples/cp/fencedlock/FencedLockBasicUsage.java

@@ -7,14 +7,20 @@
 
 import java.util.concurrent.TimeUnit;
 
+import static com.hazelcast.examples.helper.LicenseUtils.ENTERPRISE_LICENSE_KEY;
+
 /**
  * This code sample demonstrates basic usage of the locking methods available
  * in the {@link FencedLock} interface
+ *
+ * You have to set your Hazelcast Enterprise license key to make this code sample work.
+ * Please have a look at {@link com.hazelcast.examples.helper.LicenseUtils} for details.
  */
 public class FencedLockBasicUsage {
 
     public static void main(String[] args) {
         Config config = new Config();
+        config.setLicenseKey(ENTERPRISE_LICENSE_KEY);
         config.getCPSubsystemConfig().setCPMemberCount(3);
         HazelcastInstance hz1 = Hazelcast.newHazelcastInstance(config);
         HazelcastInstance hz2 = Hazelcast.newHazelcastInstance(config);

cp-subsystem/fenced-lock-force-release/src/main/java/com/hazelcast/codesamples/cp/fencedlock/ForceReleaseFencedByClosingSession.java

@@ -12,15 +12,21 @@
 import java.util.Collection;
 import java.util.concurrent.ExecutionException;
 
+import static com.hazelcast.examples.helper.LicenseUtils.ENTERPRISE_LICENSE_KEY;
+
 /**
  * This code sample demonstrates that a FencedLock can be released when
  * the CP session of its current holder is closed via the API. We can use this
  * API when we know for sure that the current lock holder is crashed.
+ *
+ * You have to set your Hazelcast Enterprise license key to make this code sample work.
+ * Please have a look at {@link com.hazelcast.examples.helper.LicenseUtils} for details.
  */
 public class ForceReleaseFencedByClosingSession {
 
     public static void main(String[] args) throws InterruptedException, ExecutionException {
         Config config = new Config();
+        config.setLicenseKey(ENTERPRISE_LICENSE_KEY);
         CPSubsystemConfig cpSubsystemConfig = config.getCPSubsystemConfig();
         cpSubsystemConfig.setCPMemberCount(3);
         HazelcastInstance hz1 = Hazelcast.newHazelcastInstance(config);

cp-subsystem/fenced-lock-lock-ownership-lost-exception/src/main/java/com/hazelcast/codesamples/cp/fencedlock/FailWhenLockOwnershipIsLost.java

@@ -13,14 +13,20 @@
 import java.util.Collection;
 import java.util.concurrent.ExecutionException;
 
+import static com.hazelcast.examples.helper.LicenseUtils.ENTERPRISE_LICENSE_KEY;
+
 /**
  * This code sample demonstrates failure of a reentrant lock() call
  * after CP session of the lock holder is closed in the CP group.
+ *
+ * You have to set your Hazelcast Enterprise license key to make this code sample work.
+ * Please have a look at {@link com.hazelcast.examples.helper.LicenseUtils} for details.
  */
 public class FailWhenLockOwnershipIsLost {
 
     public static void main(String[] args) throws InterruptedException, ExecutionException {
         Config config = new Config();
+        config.setLicenseKey(ENTERPRISE_LICENSE_KEY);
         CPSubsystemConfig cpSubsystemConfig = config.getCPSubsystemConfig();
         cpSubsystemConfig.setCPMemberCount(3);
         HazelcastInstance hz1 = Hazelcast.newHazelcastInstance(config);

cp-subsystem/fenced-lock-monotonic-fencing-tokens/src/main/java/com/hazelcast/codesamples/cp/fencedlock/MonotonicFencingTokens.java

@@ -6,15 +6,21 @@
 import com.hazelcast.core.HazelcastInstance;
 import com.hazelcast.cp.lock.FencedLock;
 
+import static com.hazelcast.examples.helper.LicenseUtils.ENTERPRISE_LICENSE_KEY;
+
 /**
  * This code sample demonstrates how fencing tokens returned by the FencedLock
  * increases every time the lock switches from the available state to the held
  * state.
+ *
+ * You have to set your Hazelcast Enterprise license key to make this code sample work.
+ * Please have a look at {@link com.hazelcast.examples.helper.LicenseUtils} for details.
  */
 public class MonotonicFencingTokens {
 
     public static void main(String[] args) {
         Config config = new Config();
+        config.setLicenseKey(ENTERPRISE_LICENSE_KEY);
         CPSubsystemConfig cpSubsystemConfig = config.getCPSubsystemConfig();
         cpSubsystemConfig.setCPMemberCount(3);
         HazelcastInstance hz1 = Hazelcast.newHazelcastInstance(config);

cp-subsystem/fenced-lock-non-reentrant-mutex/src/main/java/com/hazelcast/codesamples/cp/fencedlock/NonReentrantMutex.java

@@ -7,16 +7,22 @@
 import com.hazelcast.cp.lock.FencedLock;
 import com.hazelcast.cp.lock.exception.LockAcquireLimitReachedException;
 
+import static com.hazelcast.examples.helper.LicenseUtils.ENTERPRISE_LICENSE_KEY;
+
 /**
  * This code sample demonstrates how a FencedLock can be used
  * as a non-reentrant mutex.
+ *
+ * You have to set your Hazelcast Enterprise license key to make this code sample work.
+ * Please have a look at {@link com.hazelcast.examples.helper.LicenseUtils} for details.
  */
 public class NonReentrantMutex {
 
     public static void main(String[] args) {
         FencedLockConfig lockConfig = new FencedLockConfig("my-lock");
         lockConfig.disableReentrancy();
         Config config = new Config();
+        config.setLicenseKey(ENTERPRISE_LICENSE_KEY);
         config.getCPSubsystemConfig().setCPMemberCount(3);
         config.getCPSubsystemConfig().addLockConfig(lockConfig);
         HazelcastInstance hz1 = Hazelcast.newHazelcastInstance(config);