diff --git a/src/main/java/it/inaf/oats/vospacebackend/implementation/TransferJobManager.java b/src/main/java/it/inaf/oats/vospacebackend/implementation/TransferJobManager.java index beb07dc1583b9be480e18110c40df3b6a5c9dd96..eef00a5d9ac6b4d4360e03194ce013cc363deb5d 100644 --- a/src/main/java/it/inaf/oats/vospacebackend/implementation/TransferJobManager.java +++ b/src/main/java/it/inaf/oats/vospacebackend/implementation/TransferJobManager.java @@ -5,6 +5,7 @@ */ package it.inaf.oats.vospacebackend.implementation; +import ca.nrc.cadc.uws.server.JobDAO.JobSchema; import ca.nrc.cadc.uws.server.JobExecutor; import ca.nrc.cadc.uws.server.SimpleJobManager; import ca.nrc.cadc.uws.server.ThreadPoolExecutor; @@ -16,15 +17,17 @@ import ca.nrc.cadc.vos.server.transfers.TransferRunner; */ public class TransferJobManager extends SimpleJobManager { + private static final Long MAX_EXEC_DURATION = new Long(12*3600L); // 12 hours + private static final Long MAX_DESTRUCTION = new Long(7*24*3600L); // 1 week + private static final Long MAX_QUOTE = new Long(12*3600L); // same as exec + private JobSchema config; + public TransferJobManager() { super(); - Long MAX_EXEC_DURATION = new Long(600L);; - Long MAX_DESTRUCTION = new Long(1L+MAX_EXEC_DURATION); - Long MAX_QUOTE = new Long(600L); - + DatabaseJobPersistenceImpl jobPersist = new DatabaseJobPersistenceImpl(); - //this.config = jobPersist.getJobSchema(); + this.config = jobPersist.getJobSchema(); // exec jobs in in new thread using our custom TransferRunner JobExecutor jobExec = new ThreadPoolExecutor(jobPersist, TransferRunner.class, 6); @@ -35,4 +38,12 @@ public class TransferJobManager extends SimpleJobManager { super.setMaxDestruction(MAX_DESTRUCTION); super.setMaxQuote(MAX_QUOTE); } + + public JobSchema getConfig() { + + return config; + + } + } +