[infinispan-commits] Infinispan SVN: r1284 - trunk/core/src/main/java/org/infinispan/loaders.

[infinispan-commits at lists.jboss.org]

Author: manik.surtani at jboss.com
Date: 2009-12-10 12:34:39 -0500 (Thu, 10 Dec 2009)
New Revision: 1284

Modified:
   trunk/core/src/main/java/org/infinispan/loaders/AbstractCacheStore.java
Log:
regression

Modified: trunk/core/src/main/java/org/infinispan/loaders/AbstractCacheStore.java
===================================================================
--- trunk/core/src/main/java/org/infinispan/loaders/AbstractCacheStore.java	2009-12-10 17:31:07 UTC (rev 1283)
+++ trunk/core/src/main/java/org/infinispan/loaders/AbstractCacheStore.java	2009-12-10 17:34:39 UTC (rev 1284)
@@ -55,11 +55,12 @@
          purgerService = new WithinThreadExecutor();
       } else {
          multiThreadedPurge = supportsMultiThreadedPurge() && config.getPurgerThreads() > 1;
+         final String loaderName = getClass().getSimpleName();
          purgerService = Executors.newFixedThreadPool(supportsMultiThreadedPurge() ? config.getPurgerThreads() : 1, new ThreadFactory() {
             @Override
             public Thread newThread(Runnable r) {
                // Thread name: <cache>-<CacheStore>-<purger>-ID
-               Thread t = new Thread(r, cache.getName() + "-" + config.getCacheLoaderClassName().substring(config.getCacheLoaderClassName().lastIndexOf(".") + 1) + "-" + THREAD_COUNTER.getAndIncrement());
+               Thread t = new Thread(r, cache.getName() + "-" + loaderName + "-" + THREAD_COUNTER.getAndIncrement());
                t.setDaemon(true);
                return t;
             }