[jboss-cvs] JBossAS SVN: r77604 - projects/cluster/hibernate-jbc-cacheprovider/trunk/src/main/java/org/jboss/hibernate/jbc/cacheprovider.

[jboss-cvs-commits at lists.jboss.org]

Author: bstansberry at jboss.com
Date: 2008-08-28 12:03:03 -0400 (Thu, 28 Aug 2008)
New Revision: 77604

Added:
   projects/cluster/hibernate-jbc-cacheprovider/trunk/src/main/java/org/jboss/hibernate/jbc/cacheprovider/JndiBoundTreeCacheProvider.java
   projects/cluster/hibernate-jbc-cacheprovider/trunk/src/main/java/org/jboss/hibernate/jbc/cacheprovider/OptimisticJndiBoundTreeCacheProvider.java
Log:
[JBCLUSTER-206] Add JNDI-based providers

Added: projects/cluster/hibernate-jbc-cacheprovider/trunk/src/main/java/org/jboss/hibernate/jbc/cacheprovider/JndiBoundTreeCacheProvider.java
===================================================================
--- projects/cluster/hibernate-jbc-cacheprovider/trunk/src/main/java/org/jboss/hibernate/jbc/cacheprovider/JndiBoundTreeCacheProvider.java	                        (rev 0)
+++ projects/cluster/hibernate-jbc-cacheprovider/trunk/src/main/java/org/jboss/hibernate/jbc/cacheprovider/JndiBoundTreeCacheProvider.java	2008-08-28 16:03:03 UTC (rev 77604)
@@ -0,0 +1,106 @@
+/*
+ * JBoss, Home of Professional Open Source.
+ * Copyright 2008, Red Hat Middleware LLC, and individual contributors
+ * as indicated by the @author tags. See the copyright.txt file in the
+ * distribution for a full listing of individual contributors.
+ *
+ * This is free software; you can redistribute it and/or modify it
+ * under the terms of the GNU Lesser General Public License as
+ * published by the Free Software Foundation; either version 2.1 of
+ * the License, or (at your option) any later version.
+ *
+ * This software is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this software; if not, write to the Free
+ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
+ * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
+ */
+
+package org.jboss.hibernate.jbc.cacheprovider;
+
+import java.util.Properties;
+
+import javax.transaction.TransactionManager;
+
+import org.hibernate.cache.AbstractJndiBoundCacheProvider;
+import org.hibernate.cache.Cache;
+import org.hibernate.cache.CacheException;
+import org.hibernate.transaction.TransactionManagerLookup;
+import org.hibernate.transaction.TransactionManagerLookupFactory;
+import org.jboss.cache.TreeCache;
+import org.jboss.logging.Logger;
+import org.jboss.tm.TransactionManagerLocator;
+
+/**
+ * Support for JBossCache (TreeCache), where the cache instance is available
+ * via JNDI lookup.
+ * 
+ * @author Brian Stansberry
+ */
+public class JndiBoundTreeCacheProvider extends AbstractJndiBoundCacheProvider
+{   
+   private static final Logger log = Logger.getLogger(JndiBoundTreeCacheProvider.class);
+   
+   private boolean optimistic;
+   private TransactionManager transactionManager;
+   
+   public Cache buildCache(String regionName, Properties properties) throws CacheException
+   {
+      CacheProperties cacheProperties = new CacheProperties(properties);
+      
+      if (optimistic)
+      {
+         return new OptimisticJBCCache(getUnderlyingCache(), regionName, cacheProperties);
+      }
+      else
+      {
+         /* removed dependency on ejb3's TxUtil */
+         return new JBCCache(getUnderlyingCache(), regionName, cacheProperties, transactionManager);
+      }
+   }
+
+   public void prepare(Properties properties) throws CacheException 
+   {
+       TransactionManagerLookup transactionManagerLookup = TransactionManagerLookupFactory.getTransactionManagerLookup(properties);
+       if (transactionManagerLookup!=null) 
+       {
+           transactionManager = transactionManagerLookup.getTransactionManager(properties);
+       }
+       else
+       {
+          transactionManager = TransactionManagerLocator.getInstance().locate();
+       }
+
+       if ("OPTIMISTIC".equals(getUnderlyingCache().getNodeLockingScheme()))
+       {
+          optimistic = true;
+          log.debug("JBoss Cache is configured for optimistic locking; " +
+                  "provided Cache implementations will also implement OptimisticCache");
+       }
+   }
+
+   public boolean isMinimalPutsEnabledByDefault()
+   {
+      return true;
+   }
+
+   public long nextTimestamp()
+   {
+      return System.currentTimeMillis() / 100;
+   }
+   
+   public boolean isOptimistic()
+   {
+      return optimistic;
+   }
+
+   public TreeCache getUnderlyingCache()
+   {
+      return (TreeCache) super.getCache();
+   }
+
+}

Added: projects/cluster/hibernate-jbc-cacheprovider/trunk/src/main/java/org/jboss/hibernate/jbc/cacheprovider/OptimisticJndiBoundTreeCacheProvider.java
===================================================================
--- projects/cluster/hibernate-jbc-cacheprovider/trunk/src/main/java/org/jboss/hibernate/jbc/cacheprovider/OptimisticJndiBoundTreeCacheProvider.java	                        (rev 0)
+++ projects/cluster/hibernate-jbc-cacheprovider/trunk/src/main/java/org/jboss/hibernate/jbc/cacheprovider/OptimisticJndiBoundTreeCacheProvider.java	2008-08-28 16:03:03 UTC (rev 77604)
@@ -0,0 +1,43 @@
+/*
+ * JBoss, the OpenSource J2EE webOS
+ * 
+ * Distributable under LGPL license.
+ * See terms of license at gnu.org.
+ */
+package org.jboss.hibernate.jbc.cacheprovider;
+
+import java.util.Properties;
+
+import org.hibernate.cache.CacheException;
+import org.jboss.logging.Logger;
+
+/**
+ * Trivial {@link JndiBoundTreeCacheProvider} subclass that logs a warning in
+ * {@link #prepare(Properties) prepare} if the underlying JBoss Cache 
+ * is not configured for optimistic locking.  Like the superclass,
+ * will provide working Cache implementations whether JBoss Cache is
+ * configured for optimistic locking or not; the only added behavior
+ * is the logging of the warning if the JBoss Cache configuration doesn't 
+ * match the intent implied by the use of this class.
+ * 
+ * @author <a href="mailto:galder.zamarreno at jboss.com">Galder Zamarreno</a>
+ * @author Brian Stansberry
+ * @deprecated JndiBoundTreeCacheProvider supports both optimistic and pessimistic 
+ *             cache configurations.
+ */
+public class OptimisticJndiBoundTreeCacheProvider extends JndiBoundTreeCacheProvider 
+{
+   private static final Logger log = Logger.getLogger(OptimisticJndiBoundTreeCacheProvider.class);
+   
+   public void prepare(Properties properties) throws CacheException
+   {
+      super.prepare(properties);
+      
+      if (isOptimistic() == false)
+      {
+         log.warn("JBoss Cache is not configured for optimistic locking; " +
+         "provided Cache implementations therefore will not implement OptimisticCache");
+      }
+   }
+
+}