aboutsummaryrefslogtreecommitdiffstats
path: root/dcae-controller-core/dcae-controller-platform-server/src/main/sirius-gen/org/openecomp/dcae/controller/platform/servers/controller/DcaeControllerCluster.java
diff options
context:
space:
mode:
Diffstat (limited to 'dcae-controller-core/dcae-controller-platform-server/src/main/sirius-gen/org/openecomp/dcae/controller/platform/servers/controller/DcaeControllerCluster.java')
-rw-r--r--dcae-controller-core/dcae-controller-platform-server/src/main/sirius-gen/org/openecomp/dcae/controller/platform/servers/controller/DcaeControllerCluster.java208
1 files changed, 92 insertions, 116 deletions
diff --git a/dcae-controller-core/dcae-controller-platform-server/src/main/sirius-gen/org/openecomp/dcae/controller/platform/servers/controller/DcaeControllerCluster.java b/dcae-controller-core/dcae-controller-platform-server/src/main/sirius-gen/org/openecomp/dcae/controller/platform/servers/controller/DcaeControllerCluster.java
index 893d909..d7b96a2 100644
--- a/dcae-controller-core/dcae-controller-platform-server/src/main/sirius-gen/org/openecomp/dcae/controller/platform/servers/controller/DcaeControllerCluster.java
+++ b/dcae-controller-core/dcae-controller-platform-server/src/main/sirius-gen/org/openecomp/dcae/controller/platform/servers/controller/DcaeControllerCluster.java
@@ -18,132 +18,108 @@
* limitations under the License.
* ============LICENSE_END============================================
*/
-
+
// Autogenerated
// Do not edit. No need to extend this class.
package org.openecomp.dcae.controller.platform.servers.controller;
-
-
-
-
-import java.io.InputStream;
-
-import org.openecomp.ncomp.sirius.manager.IRequestHandler;
-import org.openecomp.ncomp.sirius.manager.ISwaggerHandler;
+import org.apache.log4j.Logger;
+import org.openecomp.dcae.controller.platform.controller.impl.ControllerClusterImpl;
+import org.openecomp.dcae.controller.platform.servers.controller.logging.ControllerClusterMessageEnum;
+import org.openecomp.dcae.controller.platform.servers.controller.logging.ControllerClusterOperationEnum;
+import org.openecomp.logger.EcompException;
+import org.openecomp.logger.StatusCodeEnum;
+import org.openecomp.ncomp.component.ApiRequestStatus;
import org.openecomp.ncomp.sirius.manager.ISiriusPlugin;
-import org.openecomp.ncomp.sirius.manager.ISiriusServer;
import org.openecomp.ncomp.sirius.manager.ISiriusProvider;
+import org.openecomp.ncomp.sirius.manager.ISiriusServer;
import org.openecomp.ncomp.sirius.manager.ManagementServer;
-import org.openecomp.ncomp.sirius.manager.SwaggerUtils;
-import org.openecomp.ncomp.sirius.function.FunctionUtils;
-import org.openecomp.ncomp.component.ApiRequestStatus;
-
-import org.apache.log4j.Logger;
-
import org.openecomp.ncomp.sirius.manager.logging.NcompLogger;
-import org.openecomp.logger.StatusCodeEnum;
-import org.openecomp.logger.EcompException;
-
-import org.eclipse.emf.common.util.EList;
-import org.eclipse.emf.ecore.EObject;
-import org.json.JSONObject;
import java.util.Date;
-import org.openecomp.dcae.controller.platform.servers.controller.logging.ControllerClusterOperationEnum;
-import org.openecomp.dcae.controller.platform.servers.controller.logging.ControllerClusterMessageEnum;
-
-
-
-
-import org.openecomp.dcae.controller.platform.controller.impl.ControllerClusterImpl;
-
-
-
public class DcaeControllerCluster extends ControllerClusterImpl implements ISiriusProvider, ISiriusPlugin {
- public static final Logger logger = Logger.getLogger(DcaeControllerCluster.class);
- static final NcompLogger ecomplogger = NcompLogger.getNcompLogger();
- public DcaeControllerClusterProvider controller;
- ISiriusServer server;
-
- public DcaeControllerCluster(ISiriusServer server) {
- this.server = server;
- this.controller = new DcaeControllerClusterProvider(server,this);
- }
-
- public void pushData(java.lang.String serverName, java.lang.String dataName) {
-
- long duration_ = 0;
- if (server != null)
- server.getServer().recordApi(null, this, "pushData", ApiRequestStatus.START, duration_,serverName,dataName);
- Date now_ = new Date();
- ecomplogger.recordAuditEventStartIfNeeded(ControllerClusterOperationEnum.ControllerCluster_pushData,server,this);
- ecomplogger.recordMetricEventStart(ControllerClusterOperationEnum.ControllerCluster_pushData,"self:" + ManagementServer.object2ref(this));
- try {
- controller.pushData(serverName,dataName);
- }
- catch (Exception e) {
- duration_ = new Date().getTime()-now_.getTime();
- if (server != null)
- server.getServer().recordApi(null, this, "pushData", ApiRequestStatus.ERROR, duration_,serverName,dataName);
- System.err.println("ERROR: " + e);
- ecomplogger.warn(ControllerClusterMessageEnum.REQUEST_FAILED_pushData, e.toString());
- EcompException e1 = EcompException.create(ControllerClusterMessageEnum.REQUEST_FAILED_pushData,e,e.getMessage());
- ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR, ControllerClusterMessageEnum.REQUEST_FAILED_pushData, e.getMessage());
- throw e1;
- }
- ecomplogger.recordMetricEventEnd();
- duration_ = new Date().getTime()-now_.getTime();
- if (server != null)
- server.getServer().recordApi(null, this, "pushData", ApiRequestStatus.OKAY, duration_,serverName,dataName);
-
- }
-
- public void receiveData(java.lang.String serverName, java.lang.String dataName, java.util.Date time, java.lang.String content) {
-
- long duration_ = 0;
- if (server != null)
- server.getServer().recordApi(null, this, "receiveData", ApiRequestStatus.START, duration_,serverName,dataName,time,content);
- Date now_ = new Date();
- ecomplogger.recordAuditEventStartIfNeeded(ControllerClusterOperationEnum.ControllerCluster_receiveData,server,this);
- ecomplogger.recordMetricEventStart(ControllerClusterOperationEnum.ControllerCluster_receiveData,"self:" + ManagementServer.object2ref(this));
- try {
- controller.receiveData(serverName,dataName,time,content);
- }
- catch (Exception e) {
- duration_ = new Date().getTime()-now_.getTime();
- if (server != null)
- server.getServer().recordApi(null, this, "receiveData", ApiRequestStatus.ERROR, duration_,serverName,dataName,time,content);
- System.err.println("ERROR: " + e);
- ecomplogger.warn(ControllerClusterMessageEnum.REQUEST_FAILED_receiveData, e.toString());
- EcompException e1 = EcompException.create(ControllerClusterMessageEnum.REQUEST_FAILED_receiveData,e,e.getMessage());
- ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR, ControllerClusterMessageEnum.REQUEST_FAILED_receiveData, e.getMessage());
- throw e1;
- }
- ecomplogger.recordMetricEventEnd();
- duration_ = new Date().getTime()-now_.getTime();
- if (server != null)
- server.getServer().recordApi(null, this, "receiveData", ApiRequestStatus.OKAY, duration_,serverName,dataName,time,content);
-
- }
-
-
-
-
-
-
-
-
- @Override
- public void start() {
- controller.start();
- }
-
- public static void ecoreSetup() {
- DcaeControllerClusterProvider.ecoreSetup();
- }
- public DcaeControllerClusterProvider getSiriusProvider() {
- return controller;
- }
+ public static final Logger logger = Logger.getLogger(DcaeControllerCluster.class);
+ static final NcompLogger ecomplogger = NcompLogger.getNcompLogger();
+ public DcaeControllerClusterProvider controller;
+ ISiriusServer server;
+
+ public DcaeControllerCluster(ISiriusServer server) {
+ this.server = server;
+ this.controller = new DcaeControllerClusterProvider(server, this);
+ }
+
+ public void pushData(java.lang.String serverName, java.lang.String dataName) {
+
+ long duration_ = 0;
+ if (server != null) {
+ server.getServer().recordApi(null, this, "pushData", ApiRequestStatus.START, duration_, serverName, dataName);
+ }
+ Date now_ = new Date();
+ ecomplogger.recordAuditEventStartIfNeeded(ControllerClusterOperationEnum.ControllerCluster_pushData, server, this);
+ ecomplogger.recordMetricEventStart(ControllerClusterOperationEnum.ControllerCluster_pushData, "self:" + ManagementServer.object2ref(this));
+ try {
+ controller.pushData(serverName, dataName);
+ } catch (Exception e) {
+ duration_ = new Date().getTime() - now_.getTime();
+ if (server != null) {
+ server.getServer().recordApi(null, this, "pushData", ApiRequestStatus.ERROR, duration_, serverName, dataName);
+ }
+ System.err.println("ERROR: " + e);
+ ecomplogger.warn(ControllerClusterMessageEnum.REQUEST_FAILED_pushData, e.toString());
+ EcompException e1 = EcompException.create(ControllerClusterMessageEnum.REQUEST_FAILED_pushData, e, e.getMessage());
+ ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR, ControllerClusterMessageEnum.REQUEST_FAILED_pushData, e.getMessage());
+ throw e1;
+ }
+ ecomplogger.recordMetricEventEnd();
+ duration_ = new Date().getTime() - now_.getTime();
+ if (server != null) {
+ server.getServer().recordApi(null, this, "pushData", ApiRequestStatus.OKAY, duration_, serverName, dataName);
+ }
+
+ }
+
+ public void receiveData(java.lang.String serverName, java.lang.String dataName, java.util.Date time, java.lang.String content) {
+
+ long duration_ = 0;
+ if (server != null) {
+ server.getServer().recordApi(null, this, "receiveData", ApiRequestStatus.START, duration_, serverName, dataName, time, content);
+ }
+ Date now_ = new Date();
+ ecomplogger.recordAuditEventStartIfNeeded(ControllerClusterOperationEnum.ControllerCluster_receiveData, server, this);
+ ecomplogger.recordMetricEventStart(ControllerClusterOperationEnum.ControllerCluster_receiveData, "self:" + ManagementServer.object2ref(this));
+ try {
+ controller.receiveData(serverName, dataName, time, content);
+ } catch (Exception e) {
+ duration_ = new Date().getTime() - now_.getTime();
+ if (server != null) {
+ server.getServer().recordApi(null, this, "receiveData", ApiRequestStatus.ERROR, duration_, serverName, dataName, time, content);
+ }
+ System.err.println("ERROR: " + e);
+ ecomplogger.warn(ControllerClusterMessageEnum.REQUEST_FAILED_receiveData, e.toString());
+ EcompException e1 = EcompException.create(ControllerClusterMessageEnum.REQUEST_FAILED_receiveData, e, e.getMessage());
+ ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR, ControllerClusterMessageEnum.REQUEST_FAILED_receiveData, e.getMessage());
+ throw e1;
+ }
+ ecomplogger.recordMetricEventEnd();
+ duration_ = new Date().getTime() - now_.getTime();
+ if (server != null) {
+ server.getServer().recordApi(null, this, "receiveData", ApiRequestStatus.OKAY, duration_, serverName, dataName, time, content);
+ }
+
+ }
+
+ @Override
+ public void start() {
+ controller.start();
+ }
+
+ public static void ecoreSetup() {
+ DcaeControllerClusterProvider.ecoreSetup();
+ }
+
+ @Override
+ public DcaeControllerClusterProvider getSiriusProvider() {
+ return controller;
+ }
}