diff options
Diffstat (limited to 'ncomp-cdap-adaptor/src/main/sirius-gen/org/openecomp/ncomp/servers/cdap/CdapCdapClusterClient.java')
| -rw-r--r-- | ncomp-cdap-adaptor/src/main/sirius-gen/org/openecomp/ncomp/servers/cdap/CdapCdapClusterClient.java | 488 |
1 files changed, 293 insertions, 195 deletions
diff --git a/ncomp-cdap-adaptor/src/main/sirius-gen/org/openecomp/ncomp/servers/cdap/CdapCdapClusterClient.java b/ncomp-cdap-adaptor/src/main/sirius-gen/org/openecomp/ncomp/servers/cdap/CdapCdapClusterClient.java index f24ff72..e49315d 100644 --- a/ncomp-cdap-adaptor/src/main/sirius-gen/org/openecomp/ncomp/servers/cdap/CdapCdapClusterClient.java +++ b/ncomp-cdap-adaptor/src/main/sirius-gen/org/openecomp/ncomp/servers/cdap/CdapCdapClusterClient.java @@ -30,6 +30,8 @@ import org.openecomp.ncomp.sirius.manager.GenericHttpClient; import org.apache.log4j.Logger; import org.openecomp.logger.EcompLogger; +import org.openecomp.logger.StatusCodeEnum; +import org.openecomp.logger.EcompException; import org.eclipse.emf.common.util.EList; import org.eclipse.emf.ecore.EClass; @@ -55,33 +57,37 @@ public class CdapCdapClusterClient extends CdapClusterImpl { CdapCdapAdaptor.ecoreSetup(); client = new GenericHttpClient(file,name); client.add("/cluster", this); + client.setVersion("ONAP-R2"); } public CdapCdapClusterClient(String file, String name1, String name2) { HighAvailabilityClient client1 = new HighAvailabilityClient(file,name1,name2); client = client1.all; // requests should be forwarded to all. client.add("/cluster", this); + client.setVersion("ONAP-R2"); } public CdapCdapClusterClient(AbstractClient c) { client = c; client.add("/resources", this); + client.setVersion("ONAP-R2"); } public void poll(String path) { - EClass c = CdapPackage.eINSTANCE.getCdapCluster(); //foo - ecomplogger.recordMetricEventStart(); - ecomplogger.setOperation(CdapClusterOperationEnum.REMOTE_poll); + EClass c = CdapPackage.eINSTANCE.getCdapCluster(); + ecomplogger.recordMetricEventStart(CdapClusterOperationEnum.CdapCluster_poll,client.getRemote()); try { client.operationPath(path, c, "poll", null); } catch (Exception e) { - ecomplogger.warn(CdapClusterMessageEnum.REMOTE_poll, e.toString()); - throw new RuntimeException("remote call failed: poll", e); + ecomplogger.warn(CdapClusterMessageEnum.REMOTE_CALL_FAILED_poll, e.toString()); + EcompException e1 = EcompException.create(CdapClusterMessageEnum.REMOTE_CALL_FAILED_poll,e,e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR,CdapClusterMessageEnum.REMOTE_CALL_FAILED_poll,e.getMessage()); + throw e1; } ecomplogger.recordMetricEventEnd(); @@ -89,16 +95,17 @@ public class CdapCdapClusterClient extends CdapClusterImpl { public java.lang.String createNamespace(String path, java.lang.String namespace) { - EClass c = CdapPackage.eINSTANCE.getCdapCluster(); //foo - ecomplogger.recordMetricEventStart(); - ecomplogger.setOperation(CdapClusterOperationEnum.REMOTE_createNamespace); + EClass c = CdapPackage.eINSTANCE.getCdapCluster(); + ecomplogger.recordMetricEventStart(CdapClusterOperationEnum.CdapCluster_createNamespace,client.getRemote()); java.lang.String res; try { res = (java.lang.String) client.operationPath(path, c, "createNamespace", null, namespace); } catch (Exception e) { - ecomplogger.warn(CdapClusterMessageEnum.REMOTE_createNamespace, e.toString()); - throw new RuntimeException("remote call failed: createNamespace", e); + ecomplogger.warn(CdapClusterMessageEnum.REMOTE_CALL_FAILED_createNamespace, e.toString()); + EcompException e1 = EcompException.create(CdapClusterMessageEnum.REMOTE_CALL_FAILED_createNamespace,e,e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR,CdapClusterMessageEnum.REMOTE_CALL_FAILED_createNamespace,e.getMessage()); + throw e1; } ecomplogger.recordMetricEventEnd(); return res; @@ -106,16 +113,17 @@ public class CdapCdapClusterClient extends CdapClusterImpl { public java.lang.String deleteNamespace(String path, java.lang.String namespace) { - EClass c = CdapPackage.eINSTANCE.getCdapCluster(); //foo - ecomplogger.recordMetricEventStart(); - ecomplogger.setOperation(CdapClusterOperationEnum.REMOTE_deleteNamespace); + EClass c = CdapPackage.eINSTANCE.getCdapCluster(); + ecomplogger.recordMetricEventStart(CdapClusterOperationEnum.CdapCluster_deleteNamespace,client.getRemote()); java.lang.String res; try { res = (java.lang.String) client.operationPath(path, c, "deleteNamespace", null, namespace); } catch (Exception e) { - ecomplogger.warn(CdapClusterMessageEnum.REMOTE_deleteNamespace, e.toString()); - throw new RuntimeException("remote call failed: deleteNamespace", e); + ecomplogger.warn(CdapClusterMessageEnum.REMOTE_CALL_FAILED_deleteNamespace, e.toString()); + EcompException e1 = EcompException.create(CdapClusterMessageEnum.REMOTE_CALL_FAILED_deleteNamespace,e,e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR,CdapClusterMessageEnum.REMOTE_CALL_FAILED_deleteNamespace,e.getMessage()); + throw e1; } ecomplogger.recordMetricEventEnd(); return res; @@ -123,16 +131,17 @@ public class CdapCdapClusterClient extends CdapClusterImpl { public java.lang.String deployApp(String path, java.lang.String namespace, java.lang.String jarfile) { - EClass c = CdapPackage.eINSTANCE.getCdapCluster(); //foo - ecomplogger.recordMetricEventStart(); - ecomplogger.setOperation(CdapClusterOperationEnum.REMOTE_deployApp); + EClass c = CdapPackage.eINSTANCE.getCdapCluster(); + ecomplogger.recordMetricEventStart(CdapClusterOperationEnum.CdapCluster_deployApp,client.getRemote()); java.lang.String res; try { res = (java.lang.String) client.operationPath(path, c, "deployApp", null, namespace,jarfile); } catch (Exception e) { - ecomplogger.warn(CdapClusterMessageEnum.REMOTE_deployApp, e.toString()); - throw new RuntimeException("remote call failed: deployApp", e); + ecomplogger.warn(CdapClusterMessageEnum.REMOTE_CALL_FAILED_deployApp, e.toString()); + EcompException e1 = EcompException.create(CdapClusterMessageEnum.REMOTE_CALL_FAILED_deployApp,e,e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR,CdapClusterMessageEnum.REMOTE_CALL_FAILED_deployApp,e.getMessage()); + throw e1; } ecomplogger.recordMetricEventEnd(); return res; @@ -140,16 +149,35 @@ public class CdapCdapClusterClient extends CdapClusterImpl { public java.lang.String loadArtifact(String path, java.lang.String namespace, java.lang.String artifactName, java.lang.String jarfile, java.lang.String version) { - EClass c = CdapPackage.eINSTANCE.getCdapCluster(); //foo - ecomplogger.recordMetricEventStart(); - ecomplogger.setOperation(CdapClusterOperationEnum.REMOTE_loadArtifact); + EClass c = CdapPackage.eINSTANCE.getCdapCluster(); + ecomplogger.recordMetricEventStart(CdapClusterOperationEnum.CdapCluster_loadArtifact,client.getRemote()); java.lang.String res; try { res = (java.lang.String) client.operationPath(path, c, "loadArtifact", null, namespace,artifactName,jarfile,version); } catch (Exception e) { - ecomplogger.warn(CdapClusterMessageEnum.REMOTE_loadArtifact, e.toString()); - throw new RuntimeException("remote call failed: loadArtifact", e); + ecomplogger.warn(CdapClusterMessageEnum.REMOTE_CALL_FAILED_loadArtifact, e.toString()); + EcompException e1 = EcompException.create(CdapClusterMessageEnum.REMOTE_CALL_FAILED_loadArtifact,e,e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR,CdapClusterMessageEnum.REMOTE_CALL_FAILED_loadArtifact,e.getMessage()); + throw e1; + } + ecomplogger.recordMetricEventEnd(); + return res; + } + + + public java.lang.String loadArtifactWithConfig(String path, java.lang.String namespace, java.lang.String artifactName, java.lang.String jarfile, java.lang.String version, java.lang.String config) { + EClass c = CdapPackage.eINSTANCE.getCdapCluster(); + ecomplogger.recordMetricEventStart(CdapClusterOperationEnum.CdapCluster_loadArtifactWithConfig,client.getRemote()); + java.lang.String res; + try { + res = (java.lang.String) client.operationPath(path, c, "loadArtifactWithConfig", null, namespace,artifactName,jarfile,version,config); + } + catch (Exception e) { + ecomplogger.warn(CdapClusterMessageEnum.REMOTE_CALL_FAILED_loadArtifactWithConfig, e.toString()); + EcompException e1 = EcompException.create(CdapClusterMessageEnum.REMOTE_CALL_FAILED_loadArtifactWithConfig,e,e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR,CdapClusterMessageEnum.REMOTE_CALL_FAILED_loadArtifactWithConfig,e.getMessage()); + throw e1; } ecomplogger.recordMetricEventEnd(); return res; @@ -157,16 +185,17 @@ public class CdapCdapClusterClient extends CdapClusterImpl { public java.lang.String deleteArtifact(String path, java.lang.String namespace, java.lang.String artifactName, java.lang.String artifactVersion) { - EClass c = CdapPackage.eINSTANCE.getCdapCluster(); //foo - ecomplogger.recordMetricEventStart(); - ecomplogger.setOperation(CdapClusterOperationEnum.REMOTE_deleteArtifact); + EClass c = CdapPackage.eINSTANCE.getCdapCluster(); + ecomplogger.recordMetricEventStart(CdapClusterOperationEnum.CdapCluster_deleteArtifact,client.getRemote()); java.lang.String res; try { res = (java.lang.String) client.operationPath(path, c, "deleteArtifact", null, namespace,artifactName,artifactVersion); } catch (Exception e) { - ecomplogger.warn(CdapClusterMessageEnum.REMOTE_deleteArtifact, e.toString()); - throw new RuntimeException("remote call failed: deleteArtifact", e); + ecomplogger.warn(CdapClusterMessageEnum.REMOTE_CALL_FAILED_deleteArtifact, e.toString()); + EcompException e1 = EcompException.create(CdapClusterMessageEnum.REMOTE_CALL_FAILED_deleteArtifact,e,e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR,CdapClusterMessageEnum.REMOTE_CALL_FAILED_deleteArtifact,e.getMessage()); + throw e1; } ecomplogger.recordMetricEventEnd(); return res; @@ -174,16 +203,17 @@ public class CdapCdapClusterClient extends CdapClusterImpl { public java.lang.String startFlow(String path, java.lang.String namespace, java.lang.String appName, java.lang.String flowId, java.lang.String extraArgs) { - EClass c = CdapPackage.eINSTANCE.getCdapCluster(); //foo - ecomplogger.recordMetricEventStart(); - ecomplogger.setOperation(CdapClusterOperationEnum.REMOTE_startFlow); + EClass c = CdapPackage.eINSTANCE.getCdapCluster(); + ecomplogger.recordMetricEventStart(CdapClusterOperationEnum.CdapCluster_startFlow,client.getRemote()); java.lang.String res; try { res = (java.lang.String) client.operationPath(path, c, "startFlow", null, namespace,appName,flowId,extraArgs); } catch (Exception e) { - ecomplogger.warn(CdapClusterMessageEnum.REMOTE_startFlow, e.toString()); - throw new RuntimeException("remote call failed: startFlow", e); + ecomplogger.warn(CdapClusterMessageEnum.REMOTE_CALL_FAILED_startFlow, e.toString()); + EcompException e1 = EcompException.create(CdapClusterMessageEnum.REMOTE_CALL_FAILED_startFlow,e,e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR,CdapClusterMessageEnum.REMOTE_CALL_FAILED_startFlow,e.getMessage()); + throw e1; } ecomplogger.recordMetricEventEnd(); return res; @@ -191,16 +221,17 @@ public class CdapCdapClusterClient extends CdapClusterImpl { public java.lang.String startWorker(String path, java.lang.String namespace, java.lang.String appName, java.lang.String workerId, java.lang.String extraArgs) { - EClass c = CdapPackage.eINSTANCE.getCdapCluster(); //foo - ecomplogger.recordMetricEventStart(); - ecomplogger.setOperation(CdapClusterOperationEnum.REMOTE_startWorker); + EClass c = CdapPackage.eINSTANCE.getCdapCluster(); + ecomplogger.recordMetricEventStart(CdapClusterOperationEnum.CdapCluster_startWorker,client.getRemote()); java.lang.String res; try { res = (java.lang.String) client.operationPath(path, c, "startWorker", null, namespace,appName,workerId,extraArgs); } catch (Exception e) { - ecomplogger.warn(CdapClusterMessageEnum.REMOTE_startWorker, e.toString()); - throw new RuntimeException("remote call failed: startWorker", e); + ecomplogger.warn(CdapClusterMessageEnum.REMOTE_CALL_FAILED_startWorker, e.toString()); + EcompException e1 = EcompException.create(CdapClusterMessageEnum.REMOTE_CALL_FAILED_startWorker,e,e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR,CdapClusterMessageEnum.REMOTE_CALL_FAILED_startWorker,e.getMessage()); + throw e1; } ecomplogger.recordMetricEventEnd(); return res; @@ -208,16 +239,17 @@ public class CdapCdapClusterClient extends CdapClusterImpl { public java.lang.String startService(String path, java.lang.String namespace, java.lang.String appName, java.lang.String serviceId, java.lang.String extraArgs) { - EClass c = CdapPackage.eINSTANCE.getCdapCluster(); //foo - ecomplogger.recordMetricEventStart(); - ecomplogger.setOperation(CdapClusterOperationEnum.REMOTE_startService); + EClass c = CdapPackage.eINSTANCE.getCdapCluster(); + ecomplogger.recordMetricEventStart(CdapClusterOperationEnum.CdapCluster_startService,client.getRemote()); java.lang.String res; try { res = (java.lang.String) client.operationPath(path, c, "startService", null, namespace,appName,serviceId,extraArgs); } catch (Exception e) { - ecomplogger.warn(CdapClusterMessageEnum.REMOTE_startService, e.toString()); - throw new RuntimeException("remote call failed: startService", e); + ecomplogger.warn(CdapClusterMessageEnum.REMOTE_CALL_FAILED_startService, e.toString()); + EcompException e1 = EcompException.create(CdapClusterMessageEnum.REMOTE_CALL_FAILED_startService,e,e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR,CdapClusterMessageEnum.REMOTE_CALL_FAILED_startService,e.getMessage()); + throw e1; } ecomplogger.recordMetricEventEnd(); return res; @@ -225,16 +257,17 @@ public class CdapCdapClusterClient extends CdapClusterImpl { public java.lang.String startApp(String path, java.lang.String namespace, java.lang.String appName) { - EClass c = CdapPackage.eINSTANCE.getCdapCluster(); //foo - ecomplogger.recordMetricEventStart(); - ecomplogger.setOperation(CdapClusterOperationEnum.REMOTE_startApp); + EClass c = CdapPackage.eINSTANCE.getCdapCluster(); + ecomplogger.recordMetricEventStart(CdapClusterOperationEnum.CdapCluster_startApp,client.getRemote()); java.lang.String res; try { res = (java.lang.String) client.operationPath(path, c, "startApp", null, namespace,appName); } catch (Exception e) { - ecomplogger.warn(CdapClusterMessageEnum.REMOTE_startApp, e.toString()); - throw new RuntimeException("remote call failed: startApp", e); + ecomplogger.warn(CdapClusterMessageEnum.REMOTE_CALL_FAILED_startApp, e.toString()); + EcompException e1 = EcompException.create(CdapClusterMessageEnum.REMOTE_CALL_FAILED_startApp,e,e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR,CdapClusterMessageEnum.REMOTE_CALL_FAILED_startApp,e.getMessage()); + throw e1; } ecomplogger.recordMetricEventEnd(); return res; @@ -242,16 +275,17 @@ public class CdapCdapClusterClient extends CdapClusterImpl { public java.lang.String stopApp(String path, java.lang.String namespace, java.lang.String appName) { - EClass c = CdapPackage.eINSTANCE.getCdapCluster(); //foo - ecomplogger.recordMetricEventStart(); - ecomplogger.setOperation(CdapClusterOperationEnum.REMOTE_stopApp); + EClass c = CdapPackage.eINSTANCE.getCdapCluster(); + ecomplogger.recordMetricEventStart(CdapClusterOperationEnum.CdapCluster_stopApp,client.getRemote()); java.lang.String res; try { res = (java.lang.String) client.operationPath(path, c, "stopApp", null, namespace,appName); } catch (Exception e) { - ecomplogger.warn(CdapClusterMessageEnum.REMOTE_stopApp, e.toString()); - throw new RuntimeException("remote call failed: stopApp", e); + ecomplogger.warn(CdapClusterMessageEnum.REMOTE_CALL_FAILED_stopApp, e.toString()); + EcompException e1 = EcompException.create(CdapClusterMessageEnum.REMOTE_CALL_FAILED_stopApp,e,e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR,CdapClusterMessageEnum.REMOTE_CALL_FAILED_stopApp,e.getMessage()); + throw e1; } ecomplogger.recordMetricEventEnd(); return res; @@ -259,16 +293,17 @@ public class CdapCdapClusterClient extends CdapClusterImpl { public java.lang.String deleteApp(String path, java.lang.String namespace, java.lang.String appName) { - EClass c = CdapPackage.eINSTANCE.getCdapCluster(); //foo - ecomplogger.recordMetricEventStart(); - ecomplogger.setOperation(CdapClusterOperationEnum.REMOTE_deleteApp); + EClass c = CdapPackage.eINSTANCE.getCdapCluster(); + ecomplogger.recordMetricEventStart(CdapClusterOperationEnum.CdapCluster_deleteApp,client.getRemote()); java.lang.String res; try { res = (java.lang.String) client.operationPath(path, c, "deleteApp", null, namespace,appName); } catch (Exception e) { - ecomplogger.warn(CdapClusterMessageEnum.REMOTE_deleteApp, e.toString()); - throw new RuntimeException("remote call failed: deleteApp", e); + ecomplogger.warn(CdapClusterMessageEnum.REMOTE_CALL_FAILED_deleteApp, e.toString()); + EcompException e1 = EcompException.create(CdapClusterMessageEnum.REMOTE_CALL_FAILED_deleteApp,e,e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR,CdapClusterMessageEnum.REMOTE_CALL_FAILED_deleteApp,e.getMessage()); + throw e1; } ecomplogger.recordMetricEventEnd(); return res; @@ -276,16 +311,17 @@ public class CdapCdapClusterClient extends CdapClusterImpl { public java.lang.String loadPreferencesApp(String path, java.lang.String namespace, java.lang.String prefsFile, java.lang.String appId) { - EClass c = CdapPackage.eINSTANCE.getCdapCluster(); //foo - ecomplogger.recordMetricEventStart(); - ecomplogger.setOperation(CdapClusterOperationEnum.REMOTE_loadPreferencesApp); + EClass c = CdapPackage.eINSTANCE.getCdapCluster(); + ecomplogger.recordMetricEventStart(CdapClusterOperationEnum.CdapCluster_loadPreferencesApp,client.getRemote()); java.lang.String res; try { res = (java.lang.String) client.operationPath(path, c, "loadPreferencesApp", null, namespace,prefsFile,appId); } catch (Exception e) { - ecomplogger.warn(CdapClusterMessageEnum.REMOTE_loadPreferencesApp, e.toString()); - throw new RuntimeException("remote call failed: loadPreferencesApp", e); + ecomplogger.warn(CdapClusterMessageEnum.REMOTE_CALL_FAILED_loadPreferencesApp, e.toString()); + EcompException e1 = EcompException.create(CdapClusterMessageEnum.REMOTE_CALL_FAILED_loadPreferencesApp,e,e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR,CdapClusterMessageEnum.REMOTE_CALL_FAILED_loadPreferencesApp,e.getMessage()); + throw e1; } ecomplogger.recordMetricEventEnd(); return res; @@ -293,16 +329,17 @@ public class CdapCdapClusterClient extends CdapClusterImpl { public java.lang.String loadPreferencesFlow(String path, java.lang.String namespace, java.lang.String prefsFile, java.lang.String appId, java.lang.String flowId) { - EClass c = CdapPackage.eINSTANCE.getCdapCluster(); //foo - ecomplogger.recordMetricEventStart(); - ecomplogger.setOperation(CdapClusterOperationEnum.REMOTE_loadPreferencesFlow); + EClass c = CdapPackage.eINSTANCE.getCdapCluster(); + ecomplogger.recordMetricEventStart(CdapClusterOperationEnum.CdapCluster_loadPreferencesFlow,client.getRemote()); java.lang.String res; try { res = (java.lang.String) client.operationPath(path, c, "loadPreferencesFlow", null, namespace,prefsFile,appId,flowId); } catch (Exception e) { - ecomplogger.warn(CdapClusterMessageEnum.REMOTE_loadPreferencesFlow, e.toString()); - throw new RuntimeException("remote call failed: loadPreferencesFlow", e); + ecomplogger.warn(CdapClusterMessageEnum.REMOTE_CALL_FAILED_loadPreferencesFlow, e.toString()); + EcompException e1 = EcompException.create(CdapClusterMessageEnum.REMOTE_CALL_FAILED_loadPreferencesFlow,e,e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR,CdapClusterMessageEnum.REMOTE_CALL_FAILED_loadPreferencesFlow,e.getMessage()); + throw e1; } ecomplogger.recordMetricEventEnd(); return res; @@ -310,16 +347,17 @@ public class CdapCdapClusterClient extends CdapClusterImpl { public java.lang.String loadPreferencesNameSpace(String path, java.lang.String namespace, java.lang.String prefsFile) { - EClass c = CdapPackage.eINSTANCE.getCdapCluster(); //foo - ecomplogger.recordMetricEventStart(); - ecomplogger.setOperation(CdapClusterOperationEnum.REMOTE_loadPreferencesNameSpace); + EClass c = CdapPackage.eINSTANCE.getCdapCluster(); + ecomplogger.recordMetricEventStart(CdapClusterOperationEnum.CdapCluster_loadPreferencesNameSpace,client.getRemote()); java.lang.String res; try { res = (java.lang.String) client.operationPath(path, c, "loadPreferencesNameSpace", null, namespace,prefsFile); } catch (Exception e) { - ecomplogger.warn(CdapClusterMessageEnum.REMOTE_loadPreferencesNameSpace, e.toString()); - throw new RuntimeException("remote call failed: loadPreferencesNameSpace", e); + ecomplogger.warn(CdapClusterMessageEnum.REMOTE_CALL_FAILED_loadPreferencesNameSpace, e.toString()); + EcompException e1 = EcompException.create(CdapClusterMessageEnum.REMOTE_CALL_FAILED_loadPreferencesNameSpace,e,e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR,CdapClusterMessageEnum.REMOTE_CALL_FAILED_loadPreferencesNameSpace,e.getMessage()); + throw e1; } ecomplogger.recordMetricEventEnd(); return res; @@ -327,16 +365,17 @@ public class CdapCdapClusterClient extends CdapClusterImpl { public java.lang.String setPreferencesApp(String path, java.lang.String namespace, java.lang.String prefsString, java.lang.String appId) { - EClass c = CdapPackage.eINSTANCE.getCdapCluster(); //foo - ecomplogger.recordMetricEventStart(); - ecomplogger.setOperation(CdapClusterOperationEnum.REMOTE_setPreferencesApp); + EClass c = CdapPackage.eINSTANCE.getCdapCluster(); + ecomplogger.recordMetricEventStart(CdapClusterOperationEnum.CdapCluster_setPreferencesApp,client.getRemote()); java.lang.String res; try { res = (java.lang.String) client.operationPath(path, c, "setPreferencesApp", null, namespace,prefsString,appId); } catch (Exception e) { - ecomplogger.warn(CdapClusterMessageEnum.REMOTE_setPreferencesApp, e.toString()); - throw new RuntimeException("remote call failed: setPreferencesApp", e); + ecomplogger.warn(CdapClusterMessageEnum.REMOTE_CALL_FAILED_setPreferencesApp, e.toString()); + EcompException e1 = EcompException.create(CdapClusterMessageEnum.REMOTE_CALL_FAILED_setPreferencesApp,e,e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR,CdapClusterMessageEnum.REMOTE_CALL_FAILED_setPreferencesApp,e.getMessage()); + throw e1; } ecomplogger.recordMetricEventEnd(); return res; @@ -344,16 +383,17 @@ public class CdapCdapClusterClient extends CdapClusterImpl { public java.lang.String setPreferencesFlow(String path, java.lang.String namespace, java.lang.String prefsString, java.lang.String appId, java.lang.String flowId) { - EClass c = CdapPackage.eINSTANCE.getCdapCluster(); //foo - ecomplogger.recordMetricEventStart(); - ecomplogger.setOperation(CdapClusterOperationEnum.REMOTE_setPreferencesFlow); + EClass c = CdapPackage.eINSTANCE.getCdapCluster(); + ecomplogger.recordMetricEventStart(CdapClusterOperationEnum.CdapCluster_setPreferencesFlow,client.getRemote()); java.lang.String res; try { res = (java.lang.String) client.operationPath(path, c, "setPreferencesFlow", null, namespace,prefsString,appId,flowId); } catch (Exception e) { - ecomplogger.warn(CdapClusterMessageEnum.REMOTE_setPreferencesFlow, e.toString()); - throw new RuntimeException("remote call failed: setPreferencesFlow", e); + ecomplogger.warn(CdapClusterMessageEnum.REMOTE_CALL_FAILED_setPreferencesFlow, e.toString()); + EcompException e1 = EcompException.create(CdapClusterMessageEnum.REMOTE_CALL_FAILED_setPreferencesFlow,e,e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR,CdapClusterMessageEnum.REMOTE_CALL_FAILED_setPreferencesFlow,e.getMessage()); + throw e1; } ecomplogger.recordMetricEventEnd(); return res; @@ -361,16 +401,17 @@ public class CdapCdapClusterClient extends CdapClusterImpl { public java.lang.String setPreferencesWorker(String path, java.lang.String namespace, java.lang.String prefsString, java.lang.String appId, java.lang.String workerId) { - EClass c = CdapPackage.eINSTANCE.getCdapCluster(); //foo - ecomplogger.recordMetricEventStart(); - ecomplogger.setOperation(CdapClusterOperationEnum.REMOTE_setPreferencesWorker); + EClass c = CdapPackage.eINSTANCE.getCdapCluster(); + ecomplogger.recordMetricEventStart(CdapClusterOperationEnum.CdapCluster_setPreferencesWorker,client.getRemote()); java.lang.String res; try { res = (java.lang.String) client.operationPath(path, c, "setPreferencesWorker", null, namespace,prefsString,appId,workerId); } catch (Exception e) { - ecomplogger.warn(CdapClusterMessageEnum.REMOTE_setPreferencesWorker, e.toString()); - throw new RuntimeException("remote call failed: setPreferencesWorker", e); + ecomplogger.warn(CdapClusterMessageEnum.REMOTE_CALL_FAILED_setPreferencesWorker, e.toString()); + EcompException e1 = EcompException.create(CdapClusterMessageEnum.REMOTE_CALL_FAILED_setPreferencesWorker,e,e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR,CdapClusterMessageEnum.REMOTE_CALL_FAILED_setPreferencesWorker,e.getMessage()); + throw e1; } ecomplogger.recordMetricEventEnd(); return res; @@ -378,16 +419,17 @@ public class CdapCdapClusterClient extends CdapClusterImpl { public java.lang.String setPreferencesService(String path, java.lang.String namespace, java.lang.String prefsString, java.lang.String appId, java.lang.String serviceId) { - EClass c = CdapPackage.eINSTANCE.getCdapCluster(); //foo - ecomplogger.recordMetricEventStart(); - ecomplogger.setOperation(CdapClusterOperationEnum.REMOTE_setPreferencesService); + EClass c = CdapPackage.eINSTANCE.getCdapCluster(); + ecomplogger.recordMetricEventStart(CdapClusterOperationEnum.CdapCluster_setPreferencesService,client.getRemote()); java.lang.String res; try { res = (java.lang.String) client.operationPath(path, c, "setPreferencesService", null, namespace,prefsString,appId,serviceId); } catch (Exception e) { - ecomplogger.warn(CdapClusterMessageEnum.REMOTE_setPreferencesService, e.toString()); - throw new RuntimeException("remote call failed: setPreferencesService", e); + ecomplogger.warn(CdapClusterMessageEnum.REMOTE_CALL_FAILED_setPreferencesService, e.toString()); + EcompException e1 = EcompException.create(CdapClusterMessageEnum.REMOTE_CALL_FAILED_setPreferencesService,e,e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR,CdapClusterMessageEnum.REMOTE_CALL_FAILED_setPreferencesService,e.getMessage()); + throw e1; } ecomplogger.recordMetricEventEnd(); return res; @@ -395,16 +437,17 @@ public class CdapCdapClusterClient extends CdapClusterImpl { public java.lang.String setPreferencesNameSpace(String path, java.lang.String namespace, java.lang.String prefsString) { - EClass c = CdapPackage.eINSTANCE.getCdapCluster(); //foo - ecomplogger.recordMetricEventStart(); - ecomplogger.setOperation(CdapClusterOperationEnum.REMOTE_setPreferencesNameSpace); + EClass c = CdapPackage.eINSTANCE.getCdapCluster(); + ecomplogger.recordMetricEventStart(CdapClusterOperationEnum.CdapCluster_setPreferencesNameSpace,client.getRemote()); java.lang.String res; try { res = (java.lang.String) client.operationPath(path, c, "setPreferencesNameSpace", null, namespace,prefsString); } catch (Exception e) { - ecomplogger.warn(CdapClusterMessageEnum.REMOTE_setPreferencesNameSpace, e.toString()); - throw new RuntimeException("remote call failed: setPreferencesNameSpace", e); + ecomplogger.warn(CdapClusterMessageEnum.REMOTE_CALL_FAILED_setPreferencesNameSpace, e.toString()); + EcompException e1 = EcompException.create(CdapClusterMessageEnum.REMOTE_CALL_FAILED_setPreferencesNameSpace,e,e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR,CdapClusterMessageEnum.REMOTE_CALL_FAILED_setPreferencesNameSpace,e.getMessage()); + throw e1; } ecomplogger.recordMetricEventEnd(); return res; @@ -412,16 +455,17 @@ public class CdapCdapClusterClient extends CdapClusterImpl { public java.lang.String setFlowRunTimeArgs(String path, java.lang.String namespace, java.lang.String appId, java.lang.String flowId, java.lang.String args) { - EClass c = CdapPackage.eINSTANCE.getCdapCluster(); //foo - ecomplogger.recordMetricEventStart(); - ecomplogger.setOperation(CdapClusterOperationEnum.REMOTE_setFlowRunTimeArgs); + EClass c = CdapPackage.eINSTANCE.getCdapCluster(); + ecomplogger.recordMetricEventStart(CdapClusterOperationEnum.CdapCluster_setFlowRunTimeArgs,client.getRemote()); java.lang.String res; try { res = (java.lang.String) client.operationPath(path, c, "setFlowRunTimeArgs", null, namespace,appId,flowId,args); } catch (Exception e) { - ecomplogger.warn(CdapClusterMessageEnum.REMOTE_setFlowRunTimeArgs, e.toString()); - throw new RuntimeException("remote call failed: setFlowRunTimeArgs", e); + ecomplogger.warn(CdapClusterMessageEnum.REMOTE_CALL_FAILED_setFlowRunTimeArgs, e.toString()); + EcompException e1 = EcompException.create(CdapClusterMessageEnum.REMOTE_CALL_FAILED_setFlowRunTimeArgs,e,e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR,CdapClusterMessageEnum.REMOTE_CALL_FAILED_setFlowRunTimeArgs,e.getMessage()); + throw e1; } ecomplogger.recordMetricEventEnd(); return res; @@ -429,16 +473,17 @@ public class CdapCdapClusterClient extends CdapClusterImpl { public java.lang.String setFlowletInstances(String path, java.lang.String namespace, java.lang.String appId, java.lang.String flowId, java.lang.String flowletId, int nInstances) { - EClass c = CdapPackage.eINSTANCE.getCdapCluster(); //foo - ecomplogger.recordMetricEventStart(); - ecomplogger.setOperation(CdapClusterOperationEnum.REMOTE_setFlowletInstances); + EClass c = CdapPackage.eINSTANCE.getCdapCluster(); + ecomplogger.recordMetricEventStart(CdapClusterOperationEnum.CdapCluster_setFlowletInstances,client.getRemote()); java.lang.String res; try { res = (java.lang.String) client.operationPath(path, c, "setFlowletInstances", null, namespace,appId,flowId,flowletId,nInstances); } catch (Exception e) { - ecomplogger.warn(CdapClusterMessageEnum.REMOTE_setFlowletInstances, e.toString()); - throw new RuntimeException("remote call failed: setFlowletInstances", e); + ecomplogger.warn(CdapClusterMessageEnum.REMOTE_CALL_FAILED_setFlowletInstances, e.toString()); + EcompException e1 = EcompException.create(CdapClusterMessageEnum.REMOTE_CALL_FAILED_setFlowletInstances,e,e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR,CdapClusterMessageEnum.REMOTE_CALL_FAILED_setFlowletInstances,e.getMessage()); + throw e1; } ecomplogger.recordMetricEventEnd(); return res; @@ -446,16 +491,17 @@ public class CdapCdapClusterClient extends CdapClusterImpl { public java.lang.String stopFlow(String path, java.lang.String namespace, java.lang.String appId, java.lang.String flowId) { - EClass c = CdapPackage.eINSTANCE.getCdapCluster(); //foo - ecomplogger.recordMetricEventStart(); - ecomplogger.setOperation(CdapClusterOperationEnum.REMOTE_stopFlow); + EClass c = CdapPackage.eINSTANCE.getCdapCluster(); + ecomplogger.recordMetricEventStart(CdapClusterOperationEnum.CdapCluster_stopFlow,client.getRemote()); java.lang.String res; try { res = (java.lang.String) client.operationPath(path, c, "stopFlow", null, namespace,appId,flowId); } catch (Exception e) { - ecomplogger.warn(CdapClusterMessageEnum.REMOTE_stopFlow, e.toString()); - throw new RuntimeException("remote call failed: stopFlow", e); + ecomplogger.warn(CdapClusterMessageEnum.REMOTE_CALL_FAILED_stopFlow, e.toString()); + EcompException e1 = EcompException.create(CdapClusterMessageEnum.REMOTE_CALL_FAILED_stopFlow,e,e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR,CdapClusterMessageEnum.REMOTE_CALL_FAILED_stopFlow,e.getMessage()); + throw e1; } ecomplogger.recordMetricEventEnd(); return res; @@ -463,16 +509,17 @@ public class CdapCdapClusterClient extends CdapClusterImpl { public java.lang.String stopWorker(String path, java.lang.String namespace, java.lang.String appId, java.lang.String workerId) { - EClass c = CdapPackage.eINSTANCE.getCdapCluster(); //foo - ecomplogger.recordMetricEventStart(); - ecomplogger.setOperation(CdapClusterOperationEnum.REMOTE_stopWorker); + EClass c = CdapPackage.eINSTANCE.getCdapCluster(); + ecomplogger.recordMetricEventStart(CdapClusterOperationEnum.CdapCluster_stopWorker,client.getRemote()); java.lang.String res; try { res = (java.lang.String) client.operationPath(path, c, "stopWorker", null, namespace,appId,workerId); } catch (Exception e) { - ecomplogger.warn(CdapClusterMessageEnum.REMOTE_stopWorker, e.toString()); - throw new RuntimeException("remote call failed: stopWorker", e); + ecomplogger.warn(CdapClusterMessageEnum.REMOTE_CALL_FAILED_stopWorker, e.toString()); + EcompException e1 = EcompException.create(CdapClusterMessageEnum.REMOTE_CALL_FAILED_stopWorker,e,e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR,CdapClusterMessageEnum.REMOTE_CALL_FAILED_stopWorker,e.getMessage()); + throw e1; } ecomplogger.recordMetricEventEnd(); return res; @@ -480,16 +527,17 @@ public class CdapCdapClusterClient extends CdapClusterImpl { public java.lang.String stopService(String path, java.lang.String namespace, java.lang.String appId, java.lang.String serviceId) { - EClass c = CdapPackage.eINSTANCE.getCdapCluster(); //foo - ecomplogger.recordMetricEventStart(); - ecomplogger.setOperation(CdapClusterOperationEnum.REMOTE_stopService); + EClass c = CdapPackage.eINSTANCE.getCdapCluster(); + ecomplogger.recordMetricEventStart(CdapClusterOperationEnum.CdapCluster_stopService,client.getRemote()); java.lang.String res; try { res = (java.lang.String) client.operationPath(path, c, "stopService", null, namespace,appId,serviceId); } catch (Exception e) { - ecomplogger.warn(CdapClusterMessageEnum.REMOTE_stopService, e.toString()); - throw new RuntimeException("remote call failed: stopService", e); + ecomplogger.warn(CdapClusterMessageEnum.REMOTE_CALL_FAILED_stopService, e.toString()); + EcompException e1 = EcompException.create(CdapClusterMessageEnum.REMOTE_CALL_FAILED_stopService,e,e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR,CdapClusterMessageEnum.REMOTE_CALL_FAILED_stopService,e.getMessage()); + throw e1; } ecomplogger.recordMetricEventEnd(); return res; @@ -497,16 +545,17 @@ public class CdapCdapClusterClient extends CdapClusterImpl { public java.lang.String truncateDataSet(String path, java.lang.String namespace, java.lang.String datasetName) { - EClass c = CdapPackage.eINSTANCE.getCdapCluster(); //foo - ecomplogger.recordMetricEventStart(); - ecomplogger.setOperation(CdapClusterOperationEnum.REMOTE_truncateDataSet); + EClass c = CdapPackage.eINSTANCE.getCdapCluster(); + ecomplogger.recordMetricEventStart(CdapClusterOperationEnum.CdapCluster_truncateDataSet,client.getRemote()); java.lang.String res; try { res = (java.lang.String) client.operationPath(path, c, "truncateDataSet", null, namespace,datasetName); } catch (Exception e) { - ecomplogger.warn(CdapClusterMessageEnum.REMOTE_truncateDataSet, e.toString()); - throw new RuntimeException("remote call failed: truncateDataSet", e); + ecomplogger.warn(CdapClusterMessageEnum.REMOTE_CALL_FAILED_truncateDataSet, e.toString()); + EcompException e1 = EcompException.create(CdapClusterMessageEnum.REMOTE_CALL_FAILED_truncateDataSet,e,e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR,CdapClusterMessageEnum.REMOTE_CALL_FAILED_truncateDataSet,e.getMessage()); + throw e1; } ecomplogger.recordMetricEventEnd(); return res; @@ -514,16 +563,17 @@ public class CdapCdapClusterClient extends CdapClusterImpl { public java.lang.String deleteDataset(String path, java.lang.String namespace, java.lang.String datasetName) { - EClass c = CdapPackage.eINSTANCE.getCdapCluster(); //foo - ecomplogger.recordMetricEventStart(); - ecomplogger.setOperation(CdapClusterOperationEnum.REMOTE_deleteDataset); + EClass c = CdapPackage.eINSTANCE.getCdapCluster(); + ecomplogger.recordMetricEventStart(CdapClusterOperationEnum.CdapCluster_deleteDataset,client.getRemote()); java.lang.String res; try { res = (java.lang.String) client.operationPath(path, c, "deleteDataset", null, namespace,datasetName); } catch (Exception e) { - ecomplogger.warn(CdapClusterMessageEnum.REMOTE_deleteDataset, e.toString()); - throw new RuntimeException("remote call failed: deleteDataset", e); + ecomplogger.warn(CdapClusterMessageEnum.REMOTE_CALL_FAILED_deleteDataset, e.toString()); + EcompException e1 = EcompException.create(CdapClusterMessageEnum.REMOTE_CALL_FAILED_deleteDataset,e,e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR,CdapClusterMessageEnum.REMOTE_CALL_FAILED_deleteDataset,e.getMessage()); + throw e1; } ecomplogger.recordMetricEventEnd(); return res; @@ -531,16 +581,17 @@ public class CdapCdapClusterClient extends CdapClusterImpl { public java.lang.String createStream(String path, java.lang.String namespace, java.lang.String newStreamId) { - EClass c = CdapPackage.eINSTANCE.getCdapCluster(); //foo - ecomplogger.recordMetricEventStart(); - ecomplogger.setOperation(CdapClusterOperationEnum.REMOTE_createStream); + EClass c = CdapPackage.eINSTANCE.getCdapCluster(); + ecomplogger.recordMetricEventStart(CdapClusterOperationEnum.CdapCluster_createStream,client.getRemote()); java.lang.String res; try { res = (java.lang.String) client.operationPath(path, c, "createStream", null, namespace,newStreamId); } catch (Exception e) { - ecomplogger.warn(CdapClusterMessageEnum.REMOTE_createStream, e.toString()); - throw new RuntimeException("remote call failed: createStream", e); + ecomplogger.warn(CdapClusterMessageEnum.REMOTE_CALL_FAILED_createStream, e.toString()); + EcompException e1 = EcompException.create(CdapClusterMessageEnum.REMOTE_CALL_FAILED_createStream,e,e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR,CdapClusterMessageEnum.REMOTE_CALL_FAILED_createStream,e.getMessage()); + throw e1; } ecomplogger.recordMetricEventEnd(); return res; @@ -548,16 +599,17 @@ public class CdapCdapClusterClient extends CdapClusterImpl { public java.lang.String deleteStream(String path, java.lang.String namespace, java.lang.String streamId) { - EClass c = CdapPackage.eINSTANCE.getCdapCluster(); //foo - ecomplogger.recordMetricEventStart(); - ecomplogger.setOperation(CdapClusterOperationEnum.REMOTE_deleteStream); + EClass c = CdapPackage.eINSTANCE.getCdapCluster(); + ecomplogger.recordMetricEventStart(CdapClusterOperationEnum.CdapCluster_deleteStream,client.getRemote()); java.lang.String res; try { res = (java.lang.String) client.operationPath(path, c, "deleteStream", null, namespace,streamId); } catch (Exception e) { - ecomplogger.warn(CdapClusterMessageEnum.REMOTE_deleteStream, e.toString()); - throw new RuntimeException("remote call failed: deleteStream", e); + ecomplogger.warn(CdapClusterMessageEnum.REMOTE_CALL_FAILED_deleteStream, e.toString()); + EcompException e1 = EcompException.create(CdapClusterMessageEnum.REMOTE_CALL_FAILED_deleteStream,e,e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR,CdapClusterMessageEnum.REMOTE_CALL_FAILED_deleteStream,e.getMessage()); + throw e1; } ecomplogger.recordMetricEventEnd(); return res; @@ -565,16 +617,17 @@ public class CdapCdapClusterClient extends CdapClusterImpl { public EList<java.lang.String> getStreamEvents(String path, java.lang.String namespace, java.lang.String streamId, java.lang.String startTime, java.lang.String endTime, int limit) { - EClass c = CdapPackage.eINSTANCE.getCdapCluster(); //foo - ecomplogger.recordMetricEventStart(); - ecomplogger.setOperation(CdapClusterOperationEnum.REMOTE_getStreamEvents); + EClass c = CdapPackage.eINSTANCE.getCdapCluster(); + ecomplogger.recordMetricEventStart(CdapClusterOperationEnum.CdapCluster_getStreamEvents,client.getRemote()); EList<java.lang.String> res; try { res = (EList<java.lang.String>) client.operationPath(path, c, "getStreamEvents", null, namespace,streamId,startTime,endTime,limit); } catch (Exception e) { - ecomplogger.warn(CdapClusterMessageEnum.REMOTE_getStreamEvents, e.toString()); - throw new RuntimeException("remote call failed: getStreamEvents", e); + ecomplogger.warn(CdapClusterMessageEnum.REMOTE_CALL_FAILED_getStreamEvents, e.toString()); + EcompException e1 = EcompException.create(CdapClusterMessageEnum.REMOTE_CALL_FAILED_getStreamEvents,e,e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR,CdapClusterMessageEnum.REMOTE_CALL_FAILED_getStreamEvents,e.getMessage()); + throw e1; } ecomplogger.recordMetricEventEnd(); return res; @@ -582,16 +635,17 @@ public class CdapCdapClusterClient extends CdapClusterImpl { public EList<java.lang.String> getStreamStats(String path, java.lang.String namespace, java.lang.String streamId, java.lang.String startTime, java.lang.String endTime, int limit) { - EClass c = CdapPackage.eINSTANCE.getCdapCluster(); //foo - ecomplogger.recordMetricEventStart(); - ecomplogger.setOperation(CdapClusterOperationEnum.REMOTE_getStreamStats); + EClass c = CdapPackage.eINSTANCE.getCdapCluster(); + ecomplogger.recordMetricEventStart(CdapClusterOperationEnum.CdapCluster_getStreamStats,client.getRemote()); EList<java.lang.String> res; try { res = (EList<java.lang.String>) client.operationPath(path, c, "getStreamStats", null, namespace,streamId,startTime,endTime,limit); } catch (Exception e) { - ecomplogger.warn(CdapClusterMessageEnum.REMOTE_getStreamStats, e.toString()); - throw new RuntimeException("remote call failed: getStreamStats", e); + ecomplogger.warn(CdapClusterMessageEnum.REMOTE_CALL_FAILED_getStreamStats, e.toString()); + EcompException e1 = EcompException.create(CdapClusterMessageEnum.REMOTE_CALL_FAILED_getStreamStats,e,e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR,CdapClusterMessageEnum.REMOTE_CALL_FAILED_getStreamStats,e.getMessage()); + throw e1; } ecomplogger.recordMetricEventEnd(); return res; @@ -599,16 +653,17 @@ public class CdapCdapClusterClient extends CdapClusterImpl { public java.lang.String sendEventToStream(String path, java.lang.String namespace, java.lang.String streamId, java.lang.String event) { - EClass c = CdapPackage.eINSTANCE.getCdapCluster(); //foo - ecomplogger.recordMetricEventStart(); - ecomplogger.setOperation(CdapClusterOperationEnum.REMOTE_sendEventToStream); + EClass c = CdapPackage.eINSTANCE.getCdapCluster(); + ecomplogger.recordMetricEventStart(CdapClusterOperationEnum.CdapCluster_sendEventToStream,client.getRemote()); java.lang.String res; try { res = (java.lang.String) client.operationPath(path, c, "sendEventToStream", null, namespace,streamId,event); } catch (Exception e) { - ecomplogger.warn(CdapClusterMessageEnum.REMOTE_sendEventToStream, e.toString()); - throw new RuntimeException("remote call failed: sendEventToStream", e); + ecomplogger.warn(CdapClusterMessageEnum.REMOTE_CALL_FAILED_sendEventToStream, e.toString()); + EcompException e1 = EcompException.create(CdapClusterMessageEnum.REMOTE_CALL_FAILED_sendEventToStream,e,e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR,CdapClusterMessageEnum.REMOTE_CALL_FAILED_sendEventToStream,e.getMessage()); + throw e1; } ecomplogger.recordMetricEventEnd(); return res; @@ -616,16 +671,17 @@ public class CdapCdapClusterClient extends CdapClusterImpl { public java.lang.String trucateStream(String path, java.lang.String namespace, java.lang.String streamId) { - EClass c = CdapPackage.eINSTANCE.getCdapCluster(); //foo - ecomplogger.recordMetricEventStart(); - ecomplogger.setOperation(CdapClusterOperationEnum.REMOTE_trucateStream); + EClass c = CdapPackage.eINSTANCE.getCdapCluster(); + ecomplogger.recordMetricEventStart(CdapClusterOperationEnum.CdapCluster_trucateStream,client.getRemote()); java.lang.String res; try { res = (java.lang.String) client.operationPath(path, c, "trucateStream", null, namespace,streamId); } catch (Exception e) { - ecomplogger.warn(CdapClusterMessageEnum.REMOTE_trucateStream, e.toString()); - throw new RuntimeException("remote call failed: trucateStream", e); + ecomplogger.warn(CdapClusterMessageEnum.REMOTE_CALL_FAILED_trucateStream, e.toString()); + EcompException e1 = EcompException.create(CdapClusterMessageEnum.REMOTE_CALL_FAILED_trucateStream,e,e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR,CdapClusterMessageEnum.REMOTE_CALL_FAILED_trucateStream,e.getMessage()); + throw e1; } ecomplogger.recordMetricEventEnd(); return res; @@ -633,16 +689,17 @@ public class CdapCdapClusterClient extends CdapClusterImpl { public java.lang.String setStreamProperties(String path, java.lang.String namespace, java.lang.String streamId, java.lang.String propsFile) { - EClass c = CdapPackage.eINSTANCE.getCdapCluster(); //foo - ecomplogger.recordMetricEventStart(); - ecomplogger.setOperation(CdapClusterOperationEnum.REMOTE_setStreamProperties); + EClass c = CdapPackage.eINSTANCE.getCdapCluster(); + ecomplogger.recordMetricEventStart(CdapClusterOperationEnum.CdapCluster_setStreamProperties,client.getRemote()); java.lang.String res; try { res = (java.lang.String) client.operationPath(path, c, "setStreamProperties", null, namespace,streamId,propsFile); } catch (Exception e) { - ecomplogger.warn(CdapClusterMessageEnum.REMOTE_setStreamProperties, e.toString()); - throw new RuntimeException("remote call failed: setStreamProperties", e); + ecomplogger.warn(CdapClusterMessageEnum.REMOTE_CALL_FAILED_setStreamProperties, e.toString()); + EcompException e1 = EcompException.create(CdapClusterMessageEnum.REMOTE_CALL_FAILED_setStreamProperties,e,e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR,CdapClusterMessageEnum.REMOTE_CALL_FAILED_setStreamProperties,e.getMessage()); + throw e1; } ecomplogger.recordMetricEventEnd(); return res; @@ -650,16 +707,17 @@ public class CdapCdapClusterClient extends CdapClusterImpl { public java.lang.String restartApp(String path, java.lang.String namespace, java.lang.String appId, java.lang.String progTypes) { - EClass c = CdapPackage.eINSTANCE.getCdapCluster(); //foo - ecomplogger.recordMetricEventStart(); - ecomplogger.setOperation(CdapClusterOperationEnum.REMOTE_restartApp); + EClass c = CdapPackage.eINSTANCE.getCdapCluster(); + ecomplogger.recordMetricEventStart(CdapClusterOperationEnum.CdapCluster_restartApp,client.getRemote()); java.lang.String res; try { res = (java.lang.String) client.operationPath(path, c, "restartApp", null, namespace,appId,progTypes); } catch (Exception e) { - ecomplogger.warn(CdapClusterMessageEnum.REMOTE_restartApp, e.toString()); - throw new RuntimeException("remote call failed: restartApp", e); + ecomplogger.warn(CdapClusterMessageEnum.REMOTE_CALL_FAILED_restartApp, e.toString()); + EcompException e1 = EcompException.create(CdapClusterMessageEnum.REMOTE_CALL_FAILED_restartApp,e,e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR,CdapClusterMessageEnum.REMOTE_CALL_FAILED_restartApp,e.getMessage()); + throw e1; } ecomplogger.recordMetricEventEnd(); return res; @@ -667,16 +725,17 @@ public class CdapCdapClusterClient extends CdapClusterImpl { public java.lang.String createApp(String path, java.lang.String namespace, java.lang.String appId, java.lang.String artifactName, java.lang.String artifactVersion, java.lang.String scope) { - EClass c = CdapPackage.eINSTANCE.getCdapCluster(); //foo - ecomplogger.recordMetricEventStart(); - ecomplogger.setOperation(CdapClusterOperationEnum.REMOTE_createApp); + EClass c = CdapPackage.eINSTANCE.getCdapCluster(); + ecomplogger.recordMetricEventStart(CdapClusterOperationEnum.CdapCluster_createApp,client.getRemote()); java.lang.String res; try { res = (java.lang.String) client.operationPath(path, c, "createApp", null, namespace,appId,artifactName,artifactVersion,scope); } catch (Exception e) { - ecomplogger.warn(CdapClusterMessageEnum.REMOTE_createApp, e.toString()); - throw new RuntimeException("remote call failed: createApp", e); + ecomplogger.warn(CdapClusterMessageEnum.REMOTE_CALL_FAILED_createApp, e.toString()); + EcompException e1 = EcompException.create(CdapClusterMessageEnum.REMOTE_CALL_FAILED_createApp,e,e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR,CdapClusterMessageEnum.REMOTE_CALL_FAILED_createApp,e.getMessage()); + throw e1; } ecomplogger.recordMetricEventEnd(); return res; @@ -684,16 +743,17 @@ public class CdapCdapClusterClient extends CdapClusterImpl { public java.lang.String createAppWithConfig(String path, java.lang.String namespace, java.lang.String appId, java.lang.String artifactName, java.lang.String artifactVersion, java.lang.String scope, java.lang.String appConfig) { - EClass c = CdapPackage.eINSTANCE.getCdapCluster(); //foo - ecomplogger.recordMetricEventStart(); - ecomplogger.setOperation(CdapClusterOperationEnum.REMOTE_createAppWithConfig); + EClass c = CdapPackage.eINSTANCE.getCdapCluster(); + ecomplogger.recordMetricEventStart(CdapClusterOperationEnum.CdapCluster_createAppWithConfig,client.getRemote()); java.lang.String res; try { res = (java.lang.String) client.operationPath(path, c, "createAppWithConfig", null, namespace,appId,artifactName,artifactVersion,scope,appConfig); } catch (Exception e) { - ecomplogger.warn(CdapClusterMessageEnum.REMOTE_createAppWithConfig, e.toString()); - throw new RuntimeException("remote call failed: createAppWithConfig", e); + ecomplogger.warn(CdapClusterMessageEnum.REMOTE_CALL_FAILED_createAppWithConfig, e.toString()); + EcompException e1 = EcompException.create(CdapClusterMessageEnum.REMOTE_CALL_FAILED_createAppWithConfig,e,e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR,CdapClusterMessageEnum.REMOTE_CALL_FAILED_createAppWithConfig,e.getMessage()); + throw e1; } ecomplogger.recordMetricEventEnd(); return res; @@ -701,16 +761,17 @@ public class CdapCdapClusterClient extends CdapClusterImpl { public java.lang.String setDatasetProperties(String path, java.lang.String namespace, java.lang.String datasetName, java.lang.String datasetProperties) { - EClass c = CdapPackage.eINSTANCE.getCdapCluster(); //foo - ecomplogger.recordMetricEventStart(); - ecomplogger.setOperation(CdapClusterOperationEnum.REMOTE_setDatasetProperties); + EClass c = CdapPackage.eINSTANCE.getCdapCluster(); + ecomplogger.recordMetricEventStart(CdapClusterOperationEnum.CdapCluster_setDatasetProperties,client.getRemote()); java.lang.String res; try { res = (java.lang.String) client.operationPath(path, c, "setDatasetProperties", null, namespace,datasetName,datasetProperties); } catch (Exception e) { - ecomplogger.warn(CdapClusterMessageEnum.REMOTE_setDatasetProperties, e.toString()); - throw new RuntimeException("remote call failed: setDatasetProperties", e); + ecomplogger.warn(CdapClusterMessageEnum.REMOTE_CALL_FAILED_setDatasetProperties, e.toString()); + EcompException e1 = EcompException.create(CdapClusterMessageEnum.REMOTE_CALL_FAILED_setDatasetProperties,e,e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR,CdapClusterMessageEnum.REMOTE_CALL_FAILED_setDatasetProperties,e.getMessage()); + throw e1; } ecomplogger.recordMetricEventEnd(); return res; @@ -718,16 +779,53 @@ public class CdapCdapClusterClient extends CdapClusterImpl { public java.lang.String setStreamTTL(String path, java.lang.String namespace, java.lang.String streamName, int ttlSeconds) { - EClass c = CdapPackage.eINSTANCE.getCdapCluster(); //foo - ecomplogger.recordMetricEventStart(); - ecomplogger.setOperation(CdapClusterOperationEnum.REMOTE_setStreamTTL); + EClass c = CdapPackage.eINSTANCE.getCdapCluster(); + ecomplogger.recordMetricEventStart(CdapClusterOperationEnum.CdapCluster_setStreamTTL,client.getRemote()); java.lang.String res; try { res = (java.lang.String) client.operationPath(path, c, "setStreamTTL", null, namespace,streamName,ttlSeconds); } catch (Exception e) { - ecomplogger.warn(CdapClusterMessageEnum.REMOTE_setStreamTTL, e.toString()); - throw new RuntimeException("remote call failed: setStreamTTL", e); + ecomplogger.warn(CdapClusterMessageEnum.REMOTE_CALL_FAILED_setStreamTTL, e.toString()); + EcompException e1 = EcompException.create(CdapClusterMessageEnum.REMOTE_CALL_FAILED_setStreamTTL,e,e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR,CdapClusterMessageEnum.REMOTE_CALL_FAILED_setStreamTTL,e.getMessage()); + throw e1; + } + ecomplogger.recordMetricEventEnd(); + return res; + } + + + public java.lang.String suspendSchedule(String path, java.lang.String namespace, java.lang.String appId, java.lang.String scheduleId) { + EClass c = CdapPackage.eINSTANCE.getCdapCluster(); + ecomplogger.recordMetricEventStart(CdapClusterOperationEnum.CdapCluster_suspendSchedule,client.getRemote()); + java.lang.String res; + try { + res = (java.lang.String) client.operationPath(path, c, "suspendSchedule", null, namespace,appId,scheduleId); + } + catch (Exception e) { + ecomplogger.warn(CdapClusterMessageEnum.REMOTE_CALL_FAILED_suspendSchedule, e.toString()); + EcompException e1 = EcompException.create(CdapClusterMessageEnum.REMOTE_CALL_FAILED_suspendSchedule,e,e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR,CdapClusterMessageEnum.REMOTE_CALL_FAILED_suspendSchedule,e.getMessage()); + throw e1; + } + ecomplogger.recordMetricEventEnd(); + return res; + } + + + public java.lang.String resumeSchedule(String path, java.lang.String namespace, java.lang.String appId, java.lang.String scheduleId) { + EClass c = CdapPackage.eINSTANCE.getCdapCluster(); + ecomplogger.recordMetricEventStart(CdapClusterOperationEnum.CdapCluster_resumeSchedule,client.getRemote()); + java.lang.String res; + try { + res = (java.lang.String) client.operationPath(path, c, "resumeSchedule", null, namespace,appId,scheduleId); + } + catch (Exception e) { + ecomplogger.warn(CdapClusterMessageEnum.REMOTE_CALL_FAILED_resumeSchedule, e.toString()); + EcompException e1 = EcompException.create(CdapClusterMessageEnum.REMOTE_CALL_FAILED_resumeSchedule,e,e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR,CdapClusterMessageEnum.REMOTE_CALL_FAILED_resumeSchedule,e.getMessage()); + throw e1; } ecomplogger.recordMetricEventEnd(); return res; |