diff options
author | VENKATESH KUMAR <vv770d@att.com> | 2017-06-26 19:48:47 -0400 |
---|---|---|
committer | VENKATESH KUMAR <vv770d@att.com> | 2017-06-26 20:02:13 -0400 |
commit | 85c567a4214faa17d28934912bb76aea282b5158 (patch) | |
tree | 91f1067a76a6f19948940c42171a323b23feae64 /src/main/java/org/openecomp/dcae/commonFunction/CommonStartup.java | |
parent | 35ad3be1673be895ec4775f3a8c905dbf17abbf1 (diff) |
Update VES for logging and exception handling
Change-Id: I44fd9535ebb3d3be88ddbf5890109bd23cd00bdc
Signed-off-by: VENKATESH KUMAR <vv770d@att.com>
Diffstat (limited to 'src/main/java/org/openecomp/dcae/commonFunction/CommonStartup.java')
-rw-r--r-- | src/main/java/org/openecomp/dcae/commonFunction/CommonStartup.java | 12 |
1 files changed, 8 insertions, 4 deletions
diff --git a/src/main/java/org/openecomp/dcae/commonFunction/CommonStartup.java b/src/main/java/org/openecomp/dcae/commonFunction/CommonStartup.java index 869a5c7..f12dd60 100644 --- a/src/main/java/org/openecomp/dcae/commonFunction/CommonStartup.java +++ b/src/main/java/org/openecomp/dcae/commonFunction/CommonStartup.java @@ -207,15 +207,18 @@ public class CommonStartup extends NsaBaseEndpoint implements Runnable EventProcessor ep = new EventProcessor (); - //Thread epThread=new Thread(ep); - //epThread.start(); executor = Executors.newFixedThreadPool(20); - executor.execute(ep); + for (int i = 0; i < 20; i++) { + executor.execute(ep); + + } } catch ( loadException | missingReqdSetting | IOException | invalidSettingValue | ServletException | InterruptedException e ) { CommonStartup.eplog.error("FATAL_STARTUP_ERROR" + e.getMessage() ); + + e.printStackTrace(); throw new RuntimeException ( e ); } finally @@ -272,7 +275,7 @@ public class CommonStartup extends NsaBaseEndpoint implements Runnable } log.debug("CommonStartup.handleEvents:EVENTS has been published successfully!"); CommonStartup.metriclog.info("EVENT_PUBLISH_END"); - //ecomplogger.debug(secloggerMessageEnum.SEC_COLLECT_AND_PULIBISH_SUCCESS); + } catch ( JSONException e ){ @@ -338,4 +341,5 @@ public class CommonStartup extends NsaBaseEndpoint implements Runnable static LinkedBlockingQueue<JSONObject> fProcessingInputQueue; private static ApiServer fTomcatServer = null; private static final Logger log = LoggerFactory.getLogger ( CommonStartup.class ); + } |