/[projects]/dao/DaoAdresseVedligehold/src/main/java/dk/daoas/adressevedligehold/coveragefileupload/AddressTask.java
ViewVC logotype

Diff of /dao/DaoAdresseVedligehold/src/main/java/dk/daoas/adressevedligehold/coveragefileupload/AddressTask.java

Parent Directory Parent Directory | Revision Log Revision Log | View Patch Patch

revision 2953 by torben, Tue Feb 16 13:09:00 2016 UTC revision 2994 by torben, Tue Mar 29 20:36:40 2016 UTC
# Line 3  package dk.daoas.adressevedligehold.file Line 3  package dk.daoas.adressevedligehold.file
3  import org.apache.commons.lang3.exception.ExceptionUtils;  import org.apache.commons.lang3.exception.ExceptionUtils;
4    
5  import dk.daoas.adressevedligehold.MailSender;  import dk.daoas.adressevedligehold.MailSender;
6  import dk.daoas.adressevedligehold.ReloadHelper;  import dk.daoas.adressevedligehold.ReloadTask;
7    import dk.daoas.adressevedligehold.afstandandenrute.AfstandAndenRuteTask;
8  import dk.daoas.adressevedligehold.tasks.Task;  import dk.daoas.adressevedligehold.tasks.Task;
9  import dk.daoas.adressevedligehold.tasks.TaskLogger;  import dk.daoas.adressevedligehold.tasks.TaskLogger;
10  import dk.daoas.adressevedligehold.util.TimingHelper;  import dk.daoas.adressevedligehold.util.TimingHelper;
11    
12  /*  /*
  * TODO: trigger afstand-anden-rute beregning  
13   *     *  
14   */   */
15    
# Line 17  public class AddressTask extends Task { Line 17  public class AddressTask extends Task {
17                    
18          private TaskLogger logger = TaskLogger.getInstance();          private TaskLogger logger = TaskLogger.getInstance();
19                    
20            private String distributor;
21            private String filename;
22            
23          AddressSource source;          AddressSource source;
24          boolean writeBack;          boolean writeBack;
25                    
# Line 24  public class AddressTask extends Task { Line 27  public class AddressTask extends Task {
27                                    
28                  this.source = source;                  this.source = source;
29                  this.writeBack = writeBack;                  this.writeBack = writeBack;
30                    
31                    this.distributor = source.getDistributor();
32                    this.filename = source.getFilename();
33          }          }
34                    
35                    
# Line 73  public class AddressTask extends Task { Line 79  public class AddressTask extends Task {
79                                                    
80                                                    
81                          if (writeBack) {                          if (writeBack) {
82                                  ReloadHelper.triggerReload( "Indlaesning/" + source.getDistributor() );                                  manager.submitTask( new ReloadTask("Indlaesning/" + source.getDistributor()) );
83                                    
84                                    
85                                    if (source.calculateDistances()) {
86                                            Task tsk = new AfstandAndenRuteTask(source.getDistributor(), AfstandAndenRuteTask.INCREMENTAL);
87                                            manager.submitTask( tsk );
88                                    }                              
89                          }                          }
90                                                    
91                            
92                                                    
93                  } catch(Exception e) {                  } catch(Exception e) {
94                                                    
# Line 93  public class AddressTask extends Task { Line 105  public class AddressTask extends Task {
105                          try {                          try {
106                                  logger.info("Cleaning up resources");                                  logger.info("Cleaning up resources");
107                                  source.close();                                  source.close();
108                                    source = null; //and release it for garbace collection
109                          } catch (Exception e) {                          } catch (Exception e) {
110                                  logger.warning("Error during cleanup: ", e );                                  logger.warning("Error during cleanup: ", e );
111                          }                                                }                      
# Line 102  public class AddressTask extends Task { Line 115  public class AddressTask extends Task {
115    
116          @Override          @Override
117          public String getDescription() {          public String getDescription() {
118                  return "AddressTask " + source.getDistributor();                  return "AddressTask " + distributor;
119          }          }
120    
121          @Override          @Override
# Line 112  public class AddressTask extends Task { Line 125  public class AddressTask extends Task {
125    
126          @Override          @Override
127          public String getDetail() {          public String getDetail() {
128                  return source.getFilename();                  return filename;
129          }          }
130    
131  }  }
Legend:
Removed from v.2953  
changed lines
  Added in v.2994
  ViewVC Help
Powered by ViewVC 1.1.20