PAYARA-223 hazelcast eclipselink cache coordination

appserver/extras/payara-micro/payara-micro-distribution/pom.xml

@@ -41,7 +41,7 @@
 
 -->
 <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd"> <modelVersion>4.0.0</modelVersion>
-    
+
     <parent>
         <groupId>fish.payara.extras.payara-micro</groupId>
         <artifactId>payara-micro-parent</artifactId>
@@ -51,9 +51,9 @@
     <groupId>fish.payara.extras</groupId>
     <artifactId>payara-micro</artifactId>
     <packaging>jar</packaging>
-    
+
     <name>Payara Micro Distribution</name>
-    
+
 
     <build>
         <defaultGoal>install</defaultGoal>
@@ -212,7 +212,7 @@
             <type>zip</type>
             <optional>true</optional>
         </dependency>
-        
+
         <!-- JMS Client dependencies -->
         <dependency>
             <groupId>org.glassfish.main.ejb</groupId>
@@ -246,7 +246,7 @@
             <optional>true</optional>
         </dependency>
         <!-- End of JMS Client Dependencies -->
-        
+
         <dependency>
             <groupId>org.glassfish.main.packager</groupId>
             <artifactId>glassfish-jsf</artifactId>
@@ -296,7 +296,7 @@
             <type>zip</type>
             <optional>true</optional>
         </dependency>
-        
+
         <!-- hazelcast package -->
         <dependency>
             <groupId>org.glassfish.main.packager</groupId>
@@ -305,7 +305,7 @@
             <type>zip</type>
             <optional>true</optional>
         </dependency>
-        
+
         <!-- healthcheck package -->
         <dependency>
             <groupId>org.glassfish.main.packager</groupId>
@@ -314,7 +314,7 @@
             <type>zip</type>
             <optional>true</optional>
         </dependency>
-        
+
         <!-- request tracing package -->
         <dependency>
             <groupId>org.glassfish.main.packager</groupId>
@@ -323,7 +323,7 @@
             <type>zip</type>
             <optional>true</optional>
         </dependency>
-        
+
         <!-- notification package -->
         <dependency>
             <groupId>org.glassfish.main.packager</groupId>
@@ -332,7 +332,7 @@
             <type>zip</type>
             <optional>true</optional>
         </dependency>
-        
+
         <!-- phonehome package -->
         <dependency>
             <groupId>org.glassfish.main.packager</groupId>
@@ -341,7 +341,7 @@
             <type>zip</type>
             <optional>true</optional>
         </dependency>
-        
+
         <!-- payara api package -->
         <dependency>
             <groupId>org.glassfish.main.packager</groupId>
@@ -350,7 +350,7 @@
             <type>zip</type>
             <optional>true</optional>
         </dependency>
-        
+
         <!-- ha package -->
         <dependency>
             <groupId>org.glassfish.main.packager</groupId>
@@ -359,7 +359,7 @@
             <type>zip</type>
             <optional>true</optional>
         </dependency>
-        
+
         <!-- payara rest endpoint package -->
         <dependency>
             <groupId>org.glassfish.main.packager</groupId>
@@ -368,7 +368,7 @@
             <type>zip</type>
             <optional>true</optional>
         </dependency>
-        
+
         <!-- Add Payara Micro Core -->
         <dependency>
             <groupId>fish.payara.micro</groupId>
@@ -377,7 +377,7 @@
             <type>jar</type>
             <optional>true</optional>
         </dependency>
-        
+
         <!-- Add Payara Micro Services -->
         <dependency>
             <groupId>fish.payara.micro</groupId>
@@ -386,7 +386,7 @@
             <type>jar</type>
             <optional>true</optional>
         </dependency>
-        
+
         <!-- Add Boot classes -->
         <dependency>
             <groupId>fish.payara.micro</groupId>
@@ -395,7 +395,7 @@
             <type>jar</type>
             <optional>true</optional>
         </dependency>
-       
+
         <!-- Add Payara Micro CDI Integration -->
         <dependency>
             <groupId>fish.payara.micro</groupId>
@@ -404,7 +404,7 @@
             <type>jar</type>
             <optional>true</optional>
         </dependency>
-        
+
         <!-- Add JBatch -->
         <dependency>
             <groupId>org.glassfish.main.batch</groupId>
@@ -427,7 +427,7 @@
             <type>jar</type>
             <optional>true</optional>
         </dependency>
-       
+
         <!-- Add Hazelcast EJB Timer Store -->
         <dependency>
             <groupId>fish.payara.ejb.timer</groupId>
@@ -436,14 +436,21 @@
             <type>jar</type>
             <optional>true</optional>
         </dependency>
+        <dependency>
+            <groupId>fish.payara.persistence.coordination</groupId>
+            <artifactId>hazelcast-eclipselink-coordination</artifactId>
+            <version>${project.version}</version>
+            <type>jar</type>
+            <optional>true</optional>
+        </dependency>
         <dependency>
             <groupId>fish.payara.jmx.monitoring</groupId>
             <artifactId>jmx-monitoring</artifactId>
             <version>${project.version}</version>
             <type>jar</type>
             <optional>true</optional>
         </dependency>
-        
+
         <!-- JMS Annotation handlers -->
         <dependency>
             <groupId>org.glassfish.main.jms</groupId>
@@ -466,9 +473,9 @@
             <version>${project.version}</version>
             <type>zip</type>
             <optional>true</optional>
-        </dependency>             
+        </dependency>
     </dependencies>
-    
+
     <profiles>
         <profile>
             <!-- generate empty javadoc jar -->

appserver/packager/glassfish-jpa/pom.xml

@@ -83,7 +83,7 @@
         <profile>
             <id>ips</id>
             <activation>
-                <activeByDefault>false</activeByDefault>  
+                <activeByDefault>false</activeByDefault>
             </activation>
             <build>
                 <plugins>
@@ -121,7 +121,7 @@
             </profile>
 
     </profiles>
-       
+
 
     <dependencies>
        <dependency>
@@ -181,6 +181,12 @@
             <groupId>org.eclipse.persistence</groupId>
             <artifactId>org.eclipse.persistence.asm</artifactId>
         </dependency>
+        <!-- JPA hazelcast cache coordination -->
+        <dependency>
+            <groupId>fish.payara.persistence.coordination</groupId>
+            <artifactId>hazelcast-eclipselink-coordination</artifactId>
+            <version>${project.version}</version>
+        </dependency>
     </dependencies>
 </project>
 

appserver/payara-appserver-modules/hazelcast-eclipselink-coordination/pom.xml

@@ -0,0 +1,40 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <groupId>org.glassfish.main</groupId>
+        <artifactId>payara-appserver-modules</artifactId>
+        <version>5.182-SNAPSHOT</version>
+    </parent>
+    <groupId>fish.payara.persistence.coordination</groupId>
+    <artifactId>hazelcast-eclipselink-coordination</artifactId>
+    <packaging>glassfish-jar</packaging>
+    <name>HZ Eclipselink Coordination</name>
+    <description>Hazelcast Based Eclipselink L2 Cache Coordination</description>
+    <developers>
+        <developer>
+            <id>svendiedrichsen</id>
+            <name>Sven Diedrichsen</name>
+            <roles>
+                <role>developer</role>
+            </roles>
+        </developer>
+    </developers>
+    <dependencies>
+        <dependency>
+            <groupId>fish.payara.payara-modules</groupId>
+            <artifactId>payara-executor-service</artifactId>
+            <version>${project.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>fish.payara.payara-modules</groupId>
+            <artifactId>hazelcast-bootstrap</artifactId>
+            <version>${project.version}</version>
+            <type>jar</type>
+        </dependency>
+        <dependency>
+            <groupId>org.eclipse.persistence</groupId>
+            <artifactId>org.eclipse.persistence.core</artifactId>
+        </dependency>
+    </dependencies>
+</project>

appserver/payara-appserver-modules/hazelcast-eclipselink-coordination/src/main/java/fish/payara/persistence/eclipselink/cache/coordination/HazelcastPayload.java

@@ -0,0 +1,116 @@
+/*
+ * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS HEADER.
+ *
+ * Copyright (c) 2016-2018 Payara Foundation and/or its affiliates. All rights reserved.
+ *
+ * The contents of this file are subject to the terms of either the GNU
+ * General Public License Version 2 only ("GPL") or the Common Development
+ * and Distribution License("CDDL") (collectively, the "License").  You
+ * may not use this file except in compliance with the License.  You can
+ * obtain a copy of the License at
+ * https://github.com/payara/Payara/blob/master/LICENSE.txt
+ * See the License for the specific
+ * language governing permissions and limitations under the License.
+ *
+ * When distributing the software, include this License Header Notice in each
+ * file and include the License file at glassfish/legal/LICENSE.txt.
+ *
+ * GPL Classpath Exception:
+ * The Payara Foundation designates this particular file as subject to the "Classpath"
+ * exception as provided by the Payara Foundation in the GPL Version 2 section of the License
+ * file that accompanied this code.
+ *
+ * Modifications:
+ * If applicable, add the following below the License Header, with the fields
+ * enclosed by brackets [] replaced by your own identifying information:
+ * "Portions Copyright [year] [name of copyright owner]"
+ *
+ * Contributor(s):
+ * If you wish your version of this file to be governed by only the CDDL or
+ * only the GPL Version 2, indicate your decision by adding "[Contributor]
+ * elects to include this software in this distribution under the [CDDL or GPL
+ * Version 2] license."  If you don't indicate a single choice of license, a
+ * recipient has the option to distribute your version of this file under
+ * either the CDDL, the GPL Version 2 or to extend the choice of license to
+ * its licensees as provided above.  However, if you add GPL Version 2 code
+ * and therefore, elected the GPL Version 2 license, then the option applies
+ * only if the new code is made subject to such option by the copyright
+ * holder.
+ */
+package fish.payara.persistence.eclipselink.cache.coordination;
+
+import org.eclipse.persistence.internal.sessions.AbstractSession;
+import org.eclipse.persistence.sessions.coordination.RemoteCommandManager;
+import org.eclipse.persistence.sessions.serializers.JavaSerializer;
+import org.eclipse.persistence.sessions.serializers.Serializer;
+
+import java.io.Serializable;
+import java.util.UUID;
+
+/**
+ * Represents the payload transported via Hazelcast topic.
+ *
+ * @author Sven Diedrichsen
+ */
+public abstract class HazelcastPayload implements Serializable {
+
+    private static final long serialVersionUID = 1;
+
+    /**
+     * This payloads id.
+     */
+    private final UUID id = UUID.randomUUID();
+
+    public abstract org.eclipse.persistence.sessions.coordination.Command getCommand(RemoteCommandManager rcm);
+
+    public UUID getId() { return id; }
+
+    /**
+     * Implements a payload for raw bytes to transfer.
+     */
+    public static class Bytes extends HazelcastPayload {
+
+        private final byte[] bytes;
+
+        public Bytes(byte[] bytes) {
+            this.bytes = bytes;
+        }
+
+        /**
+         * Returns the serialized {@link org.eclipse.persistence.sessions.coordination.Command} from
+         * the provided bytes.
+         * @param rcm The {@link RemoteCommandManager} to use for serialization.
+         * @return coordination command serialized from bytes.
+         */
+        public org.eclipse.persistence.sessions.coordination.Command getCommand(RemoteCommandManager rcm) {
+            Serializer serializer = rcm.getSerializer();
+            if (serializer == null) {
+                serializer = JavaSerializer.instance;
+            }
+            return (org.eclipse.persistence.sessions.coordination.Command)serializer.deserialize(this.bytes, (AbstractSession) rcm.getCommandProcessor());
+        }
+    }
+
+    /**
+     * Implements a payload consisting of a coordination command.
+     */
+    public static class Command extends HazelcastPayload {
+
+        private final org.eclipse.persistence.sessions.coordination.Command command;
+
+        public Command(org.eclipse.persistence.sessions.coordination.Command command) {
+            this.command = command;
+        }
+
+        /**
+         * Simply returns the original command.
+         * @param rcm The {@link RemoteCommandManager} to use for serialization. Will not be used.
+         * @return The original command.
+         */
+        @Override
+        public org.eclipse.persistence.sessions.coordination.Command getCommand(RemoteCommandManager rcm) {
+            return this.command;
+        }
+    }
+
+}