retrieved report on index results
This commit is contained in:
parent
220c6be6db
commit
e189283059
|
@ -69,6 +69,10 @@ public class IndexOnESJobNode extends AsyncJobNode {
|
||||||
log.info("Calling IndexOnES endpoint with params: "+getDatasource()+" "+getDatasourceInterface());
|
log.info("Calling IndexOnES endpoint with params: "+getDatasource()+" "+getDatasourceInterface());
|
||||||
responsePOST = client.execute(post);
|
responsePOST = client.execute(post);
|
||||||
statusCode = responsePOST.getStatusLine().getStatusCode();
|
statusCode = responsePOST.getStatusLine().getStatusCode();
|
||||||
|
try {
|
||||||
|
log.info(responsePOST.toString());
|
||||||
|
indexOnESResult = responsePOST.getEntity().getContent().toString();
|
||||||
|
} catch (Exception e) {}
|
||||||
switch (statusCode) {
|
switch (statusCode) {
|
||||||
case 200:
|
case 200:
|
||||||
log.info("index on ES completed");
|
log.info("index on ES completed");
|
||||||
|
@ -92,7 +96,7 @@ public class IndexOnESJobNode extends AsyncJobNode {
|
||||||
}
|
}
|
||||||
|
|
||||||
env.setAttribute(WorkflowsConstants.MAIN_LOG_PREFIX + "statusCode", Integer.toString(statusCode));
|
env.setAttribute(WorkflowsConstants.MAIN_LOG_PREFIX + "statusCode", Integer.toString(statusCode));
|
||||||
env.setAttribute(WorkflowsConstants.MAIN_LOG_PREFIX + "enrichResult", indexOnESResult);
|
env.setAttribute(WorkflowsConstants.MAIN_LOG_PREFIX + "indexResult", indexOnESResult);
|
||||||
|
|
||||||
log.info(indexOnESResult);
|
log.info(indexOnESResult);
|
||||||
if (statusCode!=200) {
|
if (statusCode!=200) {
|
||||||
|
|
Loading…
Reference in New Issue