lee/heritrix3
1
0
Fork 0
mirror of https://github.com/internetarchive/heritrix3.git synced 2026-07-26 17:31:46 +00:00
Code Issues Packages Projects Releases Wiki Activity

added removal listener

Browse Source
This commit is contained in:
Shriphani Palakodety
2014-03-14 16:20:50 -04:00
parent 439f78b038
commit d4d23639b6
1 changed files with 10 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
commons/src/main/java/org/archive/util/ObjectIdentityBdbManualCache.java
+10 -3
View File
@@ -67,7 +67,7 @@ import com.sleepycat.je.Environment;
*/
@SuppressWarnings("ALL")
public class ObjectIdentityBdbManualCache<V extends IdentityCacheable>
implements ObjectIdentityCache<V>, Closeable, Serializable, RemovalListener<String, V> {
implements ObjectIdentityCache<V>, Closeable, Serializable {
private static final long serialVersionUID = 1L;
private static final Logger logger =
Logger.getLogger(ObjectIdentityBdbManualCache.class.getName());
@@ -115,6 +115,13 @@ implements ObjectIdentityCache<V>, Closeable, Serializable, RemovalListener<Stri
dirtyItems = CacheBuilder.newBuilder()
.maximumSize(10000)
.expireAfterWrite(5, TimeUnit.MINUTES)
.removalListener(new RemovalListener<String, V>() {
@Override
public void onRemoval(RemovalNotification<String, V> stringVRemovalNotification) {
evictions.incrementAndGet();
diskMap.put(stringVRemovalNotification.getKey(), stringVRemovalNotification.getValue());
}
})
.<String, V>build()
.asMap();
}
@@ -372,9 +379,9 @@ implements ObjectIdentityCache<V>, Closeable, Serializable, RemovalListener<Stri
dirtyItems.put(key,val);
}
@Override
/*@Override
public void onRemoval(RemovalNotification<String, V> stringVRemovalNotification) {
evictions.incrementAndGet();
diskMap.put(stringVRemovalNotification.getKey(), stringVRemovalNotification.getValue());
}
}*/
}