[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