#638 - ENH: Add Apache Ignite as L2 cache option

src/main/java/com/avaje/ebean/plugin/SpiServer.java

@@ -46,4 +46,9 @@ public interface SpiServer extends EbeanServer {
    * Return the associated DataSource for this EbeanServer instance.
    */
   DataSource getDataSource();
+
+  /**
+   * Initialise the query cache for the given bean type.
+   */
+  boolean initQueryCache(String key);
 }

src/main/java/com/avaje/ebeaninternal/server/core/DefaultServer.java

@@ -2030,6 +2030,16 @@ public final class DefaultServer implements SpiServer, SpiEbeanServer {
     return beanDescriptorManager.getBeanDescriptorByClassName(beanClassName);
   }
 
+  @Override
+  public boolean initQueryCache(String key) {
+    BeanDescriptor<?> desc = getBeanDescriptorById(key);
+    if (desc != null) {
+      desc.queryCacheInit();
+      return true;
+    }
+    return false;
+  }
+
   /**
    * Another server in the cluster sent this event so that we can inform local
    * BeanListeners of inserts updates and deletes that occurred remotely (on

src/main/java/com/avaje/ebeaninternal/server/deploy/BeanDescriptor.java

@@ -1075,6 +1075,10 @@ public class BeanDescriptor<T> implements MetaBeanInfo, BeanType<T> {
     return cacheHelp.isCacheNotify();
   }
 
+  public void queryCacheInit() {
+    cacheHelp.queryCacheInit();
+  }
+
   /**
    * Clear the query cache.
    */

src/main/java/com/avaje/ebeaninternal/server/deploy/BeanDescriptorCacheHelp.java

@@ -59,7 +59,7 @@ public final class BeanDescriptorCacheHelp<T> {
 
   private ServerCache beanCache;
   private ServerCache naturalKeyCache;
-  private ServerCache queryCache;
+  private volatile ServerCache queryCache;
 
   public BeanDescriptorCacheHelp(BeanDescriptor<T> desc, ServerCacheManager cacheManager, CacheOptions cacheOptions,
       boolean cacheSharableBeans, BeanPropertyAssocOne<?>[] propertiesOneImported) {
@@ -148,6 +148,17 @@ public final class BeanDescriptorCacheHelp<T> {
     return cacheOptions;
   }
 
+  /**
+   * Initialise the query cache if required
+   * (as some node in the cluster already has it).
+   */
+  public void queryCacheInit() {
+    if (queryCache == null) {
+      queryLog.debug("   init {}", cacheName);
+      queryCache = cacheManager.getQueryCache(beanType);
+    }
+  }
+
   /**
    * Clear the query cache.
    */