[infinispan-commits] Infinispan SVN: r1434 - trunk/cachestore/cloud/src/main/java/org/infinispan/loaders/cloud.

infinispan-commits at lists.jboss.org infinispan-commits at lists.jboss.org
Tue Feb 2 09:34:35 EST 2010


Author: manik.surtani at jboss.com
Date: 2010-02-02 09:34:35 -0500 (Tue, 02 Feb 2010)
New Revision: 1434

Modified:
   trunk/cachestore/cloud/src/main/java/org/infinispan/loaders/cloud/CloudCacheStore.java
Log:
Default location

Modified: trunk/cachestore/cloud/src/main/java/org/infinispan/loaders/cloud/CloudCacheStore.java
===================================================================
--- trunk/cachestore/cloud/src/main/java/org/infinispan/loaders/cloud/CloudCacheStore.java	2010-02-02 14:19:21 UTC (rev 1433)
+++ trunk/cachestore/cloud/src/main/java/org/infinispan/loaders/cloud/CloudCacheStore.java	2010-02-02 14:34:35 UTC (rev 1434)
@@ -64,7 +64,7 @@
    }
 
    private String getThisContainerName() {
-      return cfg.getBucketPrefix() + "-" + cache.getName().toLowerCase();
+      return cfg.getBucketPrefix() + "-" + cache.getName().toLowerCase().replace("_", "").replace(".", "");
    }
 
    @Override
@@ -104,7 +104,7 @@
          asyncBlobStore = ctx.getAsyncBlobStore();
 
          // the "location" is not currently used.
-         if (!blobStore.containerExists(containerName)) blobStore.createContainerInLocation(null, containerName);
+         if (!blobStore.containerExists(containerName)) blobStore.createContainerInLocation("DEFAULT", containerName);
          pollFutures = !cfg.getAsyncStoreConfig().isEnabled();
       } catch (IOException ioe) {
          throw new CacheLoaderException("Unable to create context", ioe);
@@ -123,7 +123,7 @@
    }
 
    protected void fromStreamLockSafe(ObjectInput objectInput) throws CacheLoaderException {
-      String source = null;
+      String source;
       try {
          source = (String) objectInput.readObject();
       } catch (Exception e) {



More information about the infinispan-commits mailing list