HADataSource add testcase & bug fixed

This commit is contained in:
wenshao
2012-08-30 10:58:07 +08:00
parent 45ece85460
commit 7eb6fedb63
5 changed files with 22 additions and 2 deletions
@@ -255,7 +255,9 @@ public class MultiDataSource extends DataSourceAdapter implements MultiDataSourc
}
public void close() {
scheduler.shutdownNow();
if (scheduler != null) {
scheduler.shutdownNow();
}
Object[] items = this.getDataSources().values().toArray();
for (Object item : items) {