2 * ============LICENSE_START=======================================================
3 * Copyright (C) 2016-2018 Ericsson. All rights reserved.
4 * ================================================================================
5 * Licensed under the Apache License, Version 2.0 (the "License");
6 * you may not use this file except in compliance with the License.
7 * You may obtain a copy of the License at
9 * http://www.apache.org/licenses/LICENSE-2.0
11 * Unless required by applicable law or agreed to in writing, software
12 * distributed under the License is distributed on an "AS IS" BASIS,
13 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14 * See the License for the specific language governing permissions and
15 * limitations under the License.
17 * SPDX-License-Identifier: Apache-2.0
18 * ============LICENSE_END=========================================================
21 load("nashorn:mozilla_compat.js");
22 importClass(org.slf4j.LoggerFactory);
24 importClass(java.util.ArrayList);
26 importClass(org.apache.avro.generic.GenericData.Array);
27 importClass(org.apache.avro.generic.GenericRecord);
28 importClass(org.apache.avro.Schema);
30 var logger = executor.logger;
31 logger.trace("start: " + executor.subject.id);
32 logger.trace("-- infields: " + executor.inFields);
34 var rootLogger = LoggerFactory.getLogger(logger.ROOT_LOGGER_NAME);
36 var ifSituation = executor.inFields["situation"];
38 // create outfiled for decision
39 var decision = executor.subject.getOutFieldSchemaHelper("decision").createNewInstance();
40 decision.put("description", "None, everything is ok");
41 decision.put("decision", "NONE");
42 decision.put("customers", new ArrayList());
44 var returnValueType = Java.type("java.lang.Boolean");
45 if (ifSituation.get("problemID") == "NONE") {
46 logger.trace("-- no problem, everything ok");
47 var returnValue = new returnValueType(true);
49 logger.trace("-- wrong problemID <" + problemID + "> for NONE task, we should not be here");
50 rootLogger.error(executor.subject.id + " " + "-- wrong problemID <" + problemID
51 + "> for NONE task, we should not be here");
52 var returnValue = new returnValueType(false);
55 executor.outFields["decision"] = decision;
57 logger.trace("finished: " + executor.subject.id);
58 logger.debug(".d-non");