[seam-commits] Seam SVN: r10254 - trunk/src/main/org/jboss/seam/cache.

seam-commits at lists.jboss.org seam-commits at lists.jboss.org
Tue Mar 31 14:24:32 EDT 2009


Author: norman.richards at jboss.com
Date: 2009-03-31 14:24:32 -0400 (Tue, 31 Mar 2009)
New Revision: 10254

Modified:
   trunk/src/main/org/jboss/seam/cache/JbossCache2Provider.java
Log:
JBSEAM-4016

Modified: trunk/src/main/org/jboss/seam/cache/JbossCache2Provider.java
===================================================================
--- trunk/src/main/org/jboss/seam/cache/JbossCache2Provider.java	2009-03-31 12:58:06 UTC (rev 10253)
+++ trunk/src/main/org/jboss/seam/cache/JbossCache2Provider.java	2009-03-31 18:24:32 UTC (rev 10254)
@@ -21,8 +21,8 @@
 import org.jboss.seam.util.Reflections;
 
 /**
- * Implementation of CacheProvider backed by JBoss Cache 2.x.
- * for simple objects.
+ * Implementation of CacheProvider backed by JBoss Cache 2.x. for simple
+ * objects.
  * 
  * @author Sebastian Hennebrueder
  * @author Pete Muir
@@ -31,99 +31,83 @@
 @Name("org.jboss.seam.cache.cacheProvider")
 @Scope(APPLICATION)
 @BypassInterceptors
- at Install(value=false, precedence = BUILT_IN, classDependencies={"org.jboss.cache.Cache", "org.jgroups.MembershipListener"})
+ at Install(value = false, precedence = BUILT_IN, classDependencies = {"org.jboss.cache.Cache", "org.jgroups.MembershipListener"})
 @AutoCreate
-public class JbossCache2Provider extends AbstractJBossCacheProvider<Cache>
+public class JbossCache2Provider 
+    extends AbstractJBossCacheProvider<Cache> 
 {
-   
-   private static Method GET;
-   private static Method PUT;
-   private static Method REMOVE;
-   private static Method REMOVE_NODE;
-   
-   static
-   {
-      try
-      {
-         GET = Cache.class.getDeclaredMethod("get", Fqn.class, String.class);
-         PUT = Cache.class.getDeclaredMethod("put", Fqn.class, String.class, Object.class);
-         REMOVE = Cache.class.getDeclaredMethod("remove", Fqn.class, String.class);
-         REMOVE_NODE = Cache.class.getDeclaredMethod("removeNode", Fqn.class);
-      }
-      catch (Exception e)
-      {
-         throw new IllegalStateException("Unable to use JBoss Cache 2", e);
-      }
-   }
 
-   private org.jboss.cache.Cache cache;
+    private org.jboss.cache.Cache cache;
 
-   private static final LogProvider log = Logging.getLogProvider(JbossCache2Provider.class);
+    private static final LogProvider log = Logging.getLogProvider(JbossCache2Provider.class);
 
-   @Create
-   public void create()
-   {
-      log.debug("Starting JBoss Cache");
+    private static Method GET;
+    private static Method PUT;
+    private static Method REMOVE;
+    private static Method REMOVE_NODE;
 
-      try
-      {
-         CacheFactory factory = new DefaultCacheFactory();
-         cache = factory.createCache(getConfigurationAsStream());
+    static {
+        try {
+            GET = Cache.class.getDeclaredMethod("get", Fqn.class, Object.class);
+            PUT = Cache.class.getDeclaredMethod("put", Fqn.class, Object.class, Object.class);
+            REMOVE = Cache.class.getDeclaredMethod("remove", Fqn.class, Object.class);
+            REMOVE_NODE = Cache.class.getDeclaredMethod("removeNode", Fqn.class);
+        } catch (Exception e) {
+            throw new IllegalStateException("Unable to use JBoss Cache 2", e);
+        }
+    }
 
-         cache.create();
-         cache.start();
-      }
-      catch (Exception e)
-      {
-         log.error(e, e);
-         throw new IllegalStateException("Error starting JBoss Cache", e);
-      }
-   }
+    @Create
+    public void create() {
+        log.debug("Starting JBoss Cache");
 
-   @Destroy
-   public void destroy()
-   {
-      log.debug("Stopping JBoss Cache");
-      try
-      {
-         cache.stop();
-         cache.destroy();
-         cache = null;
-      }
-      catch (Exception e)
-      {
-         throw new IllegalStateException("Error stopping JBoss Cache", e);
-      }
-   }
+        try {
+            CacheFactory factory = new DefaultCacheFactory();
+            cache = factory.createCache(getConfigurationAsStream());
 
-   @Override
-   public Object get(String region, String key)
-   {
-      return Reflections.invokeAndWrap(GET, cache, getFqn(region), key);
-   }
+            cache.create();
+            cache.start();
+        } catch (Exception e) {
+            log.error(e, e);
+            throw new IllegalStateException("Error starting JBoss Cache", e);
+        }
+    }
 
-   @Override
-   public void put(String region, String key, Object object)
-   {
-      Reflections.invokeAndWrap(PUT, cache, getFqn(region), key, object);
-   }
+    @Destroy
+    public void destroy() {
+        log.debug("Stopping JBoss Cache");
+        try {
+            cache.stop();
+            cache.destroy();
+            cache = null;
+        } catch (Exception e) {
+            throw new IllegalStateException("Error stopping JBoss Cache", e);
+        }
+    }
 
-   @Override
-   public void remove(String region, String key)
-   {
-      Reflections.invokeAndWrap(REMOVE, cache, getFqn(region), key);
-   }
+    @Override
+    public Object get(String region, String key) {
+        return Reflections.invokeAndWrap(GET, cache, getFqn(region), key);
+    }
 
-   @Override
-   public void clear()
-   {
-      Reflections.invokeAndWrap(REMOVE_NODE, cache, getFqn(null));
-   }
+    @Override
+    public void put(String region, String key, Object object) {
+        Reflections.invokeAndWrap(PUT, cache, getFqn(region), key, object);
+    }
 
-   @Override
-   public Cache getDelegate()
-   {
-      return cache;
-   }
+    @Override
+    public void remove(String region, String key) {
+        Reflections.invokeAndWrap(REMOVE, cache, getFqn(region), key);
+    }
 
+    @Override
+    public void clear() {
+        Reflections.invokeAndWrap(REMOVE_NODE, cache, getFqn(null));
+    }
+
+    @Override
+    public Cache getDelegate() {
+        return cache;
+    }
+
 }
\ No newline at end of file




More information about the seam-commits mailing list