18 |
this.source = source; |
this.source = source; |
19 |
this.writeBack = writeBack; |
this.writeBack = writeBack; |
20 |
} |
} |
21 |
|
|
22 |
|
|
23 |
|
|
24 |
@Override |
@Override |
25 |
protected void taskRun() { |
protected void taskRun() throws Exception { |
26 |
|
|
27 |
try { |
try { |
28 |
TimingHelper timer = new TimingHelper(); |
TimingHelper timer = new TimingHelper(); |
29 |
|
|
30 |
|
System.out.println("Validating Source"); |
31 |
|
source.validate(); |
32 |
|
|
33 |
System.out.println("Reading data from DB"); |
System.out.println("Reading data from DB"); |
34 |
AddressManager addrManager = new AddressManager(); |
AddressManager addrManager = new AddressManager(); |
35 |
|
|
66 |
|
|
67 |
|
|
68 |
|
|
69 |
} catch (Exception e) { |
} finally { |
70 |
e.printStackTrace(); |
|
71 |
} |
try { |
72 |
|
System.out.println("Cleaning up resources"); |
73 |
|
source.close(); |
74 |
try { |
} catch (Exception e) { |
75 |
System.out.println("Cleaning up resources"); |
System.out.println("Error during cleanup: " + e.getMessage() ); |
76 |
source.close(); |
} |
|
} catch (Exception e) { |
|
|
System.out.println("Error during cleanup: " + e.getMessage() ); |
|
77 |
} |
} |
78 |
|
|
79 |
} |
} |
80 |
|
|
81 |
@Override |
@Override |