#5 add execute method with sessionId.
This commit is contained in:
parent
6d33d0415f
commit
97ac9a23ea
1 changed files with 12 additions and 1 deletions
|
@ -40,12 +40,22 @@ public class CrawlJob {
|
|||
public String execute(final JobExecutor jobExecutor,
|
||||
final String[] webConfigIds, final String[] fileConfigIds,
|
||||
final String[] dataConfigIds, final String operation) {
|
||||
final StringBuilder resultBuf = new StringBuilder();
|
||||
|
||||
// create session id
|
||||
final SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmss");
|
||||
final String sessionId = sdf.format(new Date());
|
||||
|
||||
return execute(jobExecutor, sessionId, webConfigIds, fileConfigIds,
|
||||
dataConfigIds, operation);
|
||||
|
||||
}
|
||||
|
||||
public String execute(final JobExecutor jobExecutor,
|
||||
final String sessionId, final String[] webConfigIds,
|
||||
final String[] fileConfigIds, final String[] dataConfigIds,
|
||||
final String operation) {
|
||||
final StringBuilder resultBuf = new StringBuilder();
|
||||
|
||||
if (jobExecutor != null) {
|
||||
jobExecutor.addShutdownListener(new ShutdownListener() {
|
||||
@Override
|
||||
|
@ -70,6 +80,7 @@ public class CrawlJob {
|
|||
}
|
||||
|
||||
return resultBuf.toString();
|
||||
|
||||
}
|
||||
|
||||
}
|
||||
|
|
Loading…
Add table
Reference in a new issue