commit 29b7e67bca2e8d75297ef0e610954303459a8f9b
author Adrian Cole <adrian.f.cole@gmail.com> Wed Apr 10 13:45:53 2013 -0700
committer Adrian Cole <adrian.f.cole@gmail.com> Wed Apr 10 13:45:53 2013 -0700
tree 99e088b661a6499aa99337d553ebe823007aa3cd
parent b82cf36018a5df8e0a426a1526339d8295e594c4
parent 05b443fe4d151b971ac671120f95219648ca3456

Merge pull request #1522 from maginatics/memorize-swift-tempurl-keys-1.5.x

Memoize Swift TempURL keys

apis/swift/src/main/java/org/jclouds/openstack/swift/blobstore/config/TemporaryUrlExtensionModule.java

diff --git a/apis/swift/src/main/java/org/jclouds/openstack/swift/blobstore/config/TemporaryUrlExtensionModule.java b/apis/swift/src/main/java/org/jclouds/openstack/swift/blobstore/config/TemporaryUrlExtensionModule.java
index 71bcd40..81e3e3f 100644
--- a/apis/swift/src/main/java/org/jclouds/openstack/swift/blobstore/config/TemporaryUrlExtensionModule.java
+++ b/apis/swift/src/main/java/org/jclouds/openstack/swift/blobstore/config/TemporaryUrlExtensionModule.java
@@ -19,6 +19,10 @@
 package org.jclouds.openstack.swift.blobstore.config;
 
 import static org.jclouds.rest.config.BinderUtils.bindClientAndAsyncClient;
+import static org.jclouds.Constants.PROPERTY_SESSION_INTERVAL;
+
+import java.util.concurrent.TimeUnit;
+import javax.inject.Singleton;
 
 import org.jclouds.blobstore.BlobRequestSigner;
 import org.jclouds.date.TimeStamp;
@@ -33,7 +37,10 @@
 import org.jclouds.openstack.swift.suppliers.ReturnOrFetchTemporaryUrlKey;
 
 import com.google.common.base.Supplier;
+import com.google.common.base.Suppliers;
 import com.google.inject.AbstractModule;
+import com.google.inject.Inject;
+import com.google.inject.name.Named;
 import com.google.inject.Provides;
 import com.google.inject.TypeLiteral;
 
@@ -85,7 +92,24 @@
       bindRequestSigner();
       bindTemporaryUrlKeyApi();
       bind(new TypeLiteral<Supplier<String>>() {
-      }).annotatedWith(TemporaryUrlKey.class).to(ReturnOrFetchTemporaryUrlKey.class);
+      }).annotatedWith(TemporaryUrlKey.class).to(ReturnOrFetchTemporaryUrlKeyMemoized.class);
+   }
+
+   @Singleton
+   private static class ReturnOrFetchTemporaryUrlKeyMemoized implements Supplier<String> {
+      private final Supplier<String> delegate;
+
+      @Inject
+      private ReturnOrFetchTemporaryUrlKeyMemoized(TemporaryUrlKeyApi client,
+            @Named(PROPERTY_SESSION_INTERVAL) long sessionInterval) {
+         this.delegate = Suppliers.memoizeWithExpiration(
+               new ReturnOrFetchTemporaryUrlKey(client), sessionInterval, TimeUnit.SECONDS);
+      }
+
+      @Override
+      public String get() {
+         return delegate.get();
+      }
    }
 
    protected abstract void bindRequestSigner();
@@ -94,4 +118,4 @@
       bindClientAndAsyncClient(binder(), TemporaryUrlKeyApi.class, TemporaryUrlKeyAsyncApi.class);
    }
 
-}
\ No newline at end of file
+}