package at.gv.egovernment.moa.id.configuration.utils; import java.util.Calendar; import java.util.Date; import java.util.List; import org.apache.log4j.Logger; import at.gv.egovernment.moa.id.commons.db.ConfigurationDBRead; import at.gv.egovernment.moa.id.commons.db.ConfigurationDBUtils; import at.gv.egovernment.moa.id.commons.db.dao.config.UserDatabase; import at.gv.egovernment.moa.id.configuration.config.ConfigurationProvider; import at.gv.egovernment.moa.id.configuration.exception.ConfigurationException; import at.gv.egovernment.moa.id.configuration.helper.DateTimeHelper; public class UserRequestCleaner implements Runnable { private static final Logger log = Logger.getLogger(UserRequestCleaner.class); private static final long SESSION_CLEANUP_INTERVAL = 60 * 60; // 60 min public void run() { while (true) { try { ConfigurationProvider config = ConfigurationProvider.getInstance(); List userrequests = ConfigurationDBRead.getAllOpenUsersRequests(); if (userrequests != null) { Calendar cal = Calendar.getInstance(); cal.add(Calendar.HOUR, config.getUserRequestCleanUpDelay()*-1); Date cleanupdate = cal.getTime(); for(UserDatabase dbuser : userrequests) { Date requestdate = DateTimeHelper.parseDateTime(dbuser.getLastLogin()); if (requestdate != null && requestdate.after(cleanupdate)) { log.info("Remove UserRequest from Database"); ConfigurationDBUtils.delete(dbuser); } } } Thread.sleep(SESSION_CLEANUP_INTERVAL * 1000); } catch (ConfigurationException e) { log.info("UserRequestCleaner can not load configuration", e); } catch (InterruptedException e) { } finally { ConfigurationDBUtils.closeSession(); } } } /** * start the sessionCleaner */ public static void start() { // start the session cleanup thread Thread sessionCleaner = new Thread(new UserRequestCleaner()); sessionCleaner.setName("UserRequestCleaner"); sessionCleaner.setDaemon(true); sessionCleaner.setPriority(Thread.MIN_PRIORITY); sessionCleaner.start(); } }