From 6d09f43225ba2e0f6d7b0583f843c858a1015807 Mon Sep 17 00:00:00 2001
From: Thomas Lenz <thomas.lenz@egiz.gv.at>
Date: Thu, 26 Jul 2018 10:30:14 +0200
Subject: namespace refactoring

---
 .../connector/storage/CacheWitheIDASBackend.java   | 33 ++++++++++++++++++++++
 1 file changed, 33 insertions(+)
 create mode 100644 connector/src/main/java/at/asitplus/eidas/specific/connector/storage/CacheWitheIDASBackend.java

(limited to 'connector/src/main/java/at/asitplus/eidas/specific/connector/storage/CacheWitheIDASBackend.java')

diff --git a/connector/src/main/java/at/asitplus/eidas/specific/connector/storage/CacheWitheIDASBackend.java b/connector/src/main/java/at/asitplus/eidas/specific/connector/storage/CacheWitheIDASBackend.java
new file mode 100644
index 00000000..ac0abda0
--- /dev/null
+++ b/connector/src/main/java/at/asitplus/eidas/specific/connector/storage/CacheWitheIDASBackend.java
@@ -0,0 +1,33 @@
+package at.asitplus.eidas.specific.connector.storage;
+
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.Iterator;
+import java.util.List;
+
+import eu.eidas.auth.commons.cache.ConcurrentMapService;
+import eu.eidas.auth.commons.tx.AbstractCorrelationMap;
+
+public class CacheWitheIDASBackend extends AbstractCorrelationMap<TransactionStoreElement> {
+
+	protected CacheWitheIDASBackend(ConcurrentMapService concurrentMapService) {
+		super(concurrentMapService);
+	}
+	
+	public List<String> clean(Date now, long dataTimeOut) {
+		List<String> result = new ArrayList<String>();
+		Iterator<String> iterator = map.keySet().iterator();
+		while (iterator.hasNext()) {
+			String key = iterator.next();			
+			if (map.containsKey(key)) {
+				TransactionStoreElement element = map.get(key);				
+				if (now.getTime() - element.getCreated().getTime() > dataTimeOut)
+					result.add(key);
+			}										
+		}
+		
+		return result;
+		
+	}
+
+}
-- 
cgit v1.2.3