Apache
/
jclouds
mirror of https://github.com/apache/jclouds.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #1416 from maginatics/memorize-swift-tempurl-keys 

Memoize Swift TempURL keys
This commit is contained in:
Adrian Cole 2013-03-13 12:29:36 -07:00
parent 7596205774 917c03c7bf
commit 22202013db
1 changed files with 25 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -19,6 +19,10 @@
package org.jclouds.openstack.swift.blobstore.config;
import static org.jclouds.rest.config.BinderUtils.bindHttpApi;
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.extensions.TemporaryUrlKeyAsyncApi;
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 @@ public abstract class TemporaryUrlExtensionModule<A extends CommonSwiftAsyncClie
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();