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

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

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

revision 2949 by torben, Tue Feb 16 09:38:13 2016 UTC revision 3013 by torben, Wed Apr 20 14:15:02 2016 UTC
# Line 2  package dk.daoas.adressevedligehold.file Line 2  package dk.daoas.adressevedligehold.file
2    
3  import org.apache.commons.lang3.exception.ExceptionUtils;  import org.apache.commons.lang3.exception.ExceptionUtils;
4    
5  import dk.daoas.adressevedligehold.ReloadHelper;  import dk.daoas.adressevedligehold.MailSender;
6    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 16  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 23  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 48  public class AddressTask extends Task { Line 55  public class AddressTask extends Task {
55                                                    
56                          AddressSourceEntry entry;                          AddressSourceEntry entry;
57                          while ( (entry = source.getNextEntry()) != null) {                          while ( (entry = source.getNextEntry()) != null) {
58                                  if (super.abort) {                                  if (isAborted()) {
59                                          break;                                          break;
60                                  }                                  }
61                                                                    
# Line 72  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 84  public class AddressTask extends Task { Line 97  public class AddressTask extends Task {
97                          body += "<br><br>";                          body += "<br><br>";
98                          body += "Exception:<br>";                          body += "Exception:<br>";
99                          body += ExceptionUtils.getStackTrace(e);                          body += ExceptionUtils.getStackTrace(e);
100                          AddressReport.sendMail(subject, body);                          MailSender.sendMail(subject, body);
101                                                    
102                          throw e; //rethrow exception                          throw e; //rethrow exception
103                  } finally  {                  } finally  {
# Line 92  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 101  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 111  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.2949  
changed lines
  Added in v.3013
  ViewVC Help
Powered by ViewVC 1.1.20