* ============LICENSE_START=======================================================
* ONAP : APPC
* ================================================================================
- * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
+ * Copyright (C) 2017-2018 AT&T Intellectual Property. All rights reserved.
* ================================================================================
* Copyright (C) 2017 Amdocs
* =============================================================================
* See the License for the specific language governing permissions and
* limitations under the License.
*
- * ECOMP is a trademark and service mark of AT&T Intellectual Property.
* ============LICENSE_END=========================================================
*/
public class Converter {
- public static final String ISO_FORMAT = "yyyy-MM-dd'T'HH:mm:ss.SSS'Z'";
- public static final String MODE_FLAG = "MODE";
- public static final String FORCE_FLAG = "FORCE";
- public static final String TTL_FLAG = "TTL";
- public final static String DMaaP_ROOT_VALUE = "output";
+ private static final String ISO_FORMAT = "yyyy-MM-dd'T'HH:mm:ss.SSS'Z'";
+ private final static String DMaaP_ROOT_VALUE = "output";
private static final SimpleDateFormat isoFormatter = new SimpleDateFormat(ISO_FORMAT);
- private static final EELFLogger logger = EELFManager.getInstance().getLogger(Converter.class);
static {
isoFormatter.setTimeZone(TimeZone.getTimeZone("UTC"));
}
outObj = new HealthCheckOutputBuilder();
((HealthCheckOutputBuilder)outObj).setCommonHeader(commonHeader);
((HealthCheckOutputBuilder)outObj).setStatus(status);
+ ((HealthCheckOutputBuilder)outObj).setPayload(payload);
return outObj;
case LiveUpgrade:
outObj = new LiveUpgradeOutputBuilder();
((ConfigModifyOutputBuilder)outObj).setPayload(payload);
return outObj;
case ConfigScaleOut:
- outObj = new ConfigScaleoutOutputBuilder();
- ((ConfigScaleoutOutputBuilder)outObj).setCommonHeader(commonHeader);
- ((ConfigScaleoutOutputBuilder)outObj).setStatus(status);
- ((ConfigScaleoutOutputBuilder)outObj).setPayload(payload);
+ outObj = new ConfigScaleOutOutputBuilder();
+ ((ConfigScaleOutOutputBuilder)outObj).setCommonHeader(commonHeader);
+ ((ConfigScaleOutOutputBuilder)outObj).setStatus(status);
+ ((ConfigScaleOutOutputBuilder)outObj).setPayload(payload);
return outObj;
case ConfigRestore:
outObj = new ConfigRestoreOutputBuilder();
((RebuildOutputBuilder)outObj).setCommonHeader(commonHeader);
((RebuildOutputBuilder)outObj).setStatus(status);
return outObj;
+ case Reboot:
+ outObj = new RebootOutputBuilder();
+ ((RebootOutputBuilder)outObj).setCommonHeader(commonHeader);
+ ((RebootOutputBuilder)outObj).setStatus(status);
+ return outObj;
case Migrate:
outObj = new MigrateOutputBuilder();
((MigrateOutputBuilder)outObj).setCommonHeader(commonHeader);
((StartApplicationOutputBuilder)outObj).setCommonHeader(commonHeader);
((StartApplicationOutputBuilder)outObj).setStatus(status);
return outObj;
+ case QuiesceTraffic:
+ outObj = new QuiesceTrafficOutputBuilder();
+ ((QuiesceTrafficOutputBuilder)outObj).setCommonHeader(commonHeader);
+ ((QuiesceTrafficOutputBuilder)outObj).setStatus(status);
+ return outObj;
+ case ResumeTraffic:
+ outObj = new ResumeTrafficOutputBuilder();
+ ((ResumeTrafficOutputBuilder)outObj).setCommonHeader(commonHeader);
+ ((ResumeTrafficOutputBuilder)outObj).setStatus(status);
+ return outObj;
+ case UpgradeSoftware:
+ outObj = new UpgradeSoftwareOutputBuilder();
+ ((UpgradeSoftwareOutputBuilder)outObj).setCommonHeader(commonHeader);
+ ((UpgradeSoftwareOutputBuilder)outObj).setStatus(status);
+ return outObj;
+ case UpgradePostCheck:
+ outObj = new UpgradePostCheckOutputBuilder();
+ ((UpgradePostCheckOutputBuilder)outObj).setCommonHeader(commonHeader);
+ ((UpgradePostCheckOutputBuilder)outObj).setStatus(status);
+ ((UpgradePostCheckOutputBuilder)outObj).setPayload(payload);
+ return outObj;
+ case UpgradeBackup:
+ outObj = new UpgradeBackupOutputBuilder();
+ ((UpgradeBackupOutputBuilder)outObj).setCommonHeader(commonHeader);
+ ((UpgradeBackupOutputBuilder)outObj).setStatus(status);
+ return outObj;
+ case UpgradeBackout:
+ outObj = new UpgradeBackoutOutputBuilder();
+ ((UpgradeBackoutOutputBuilder)outObj).setCommonHeader(commonHeader);
+ ((UpgradeBackoutOutputBuilder)outObj).setStatus(status);
+ return outObj;
+ case UpgradePreCheck:
+ outObj = new UpgradePreCheckOutputBuilder();
+ ((UpgradePreCheckOutputBuilder)outObj).setCommonHeader(commonHeader);
+ ((UpgradePreCheckOutputBuilder)outObj).setStatus(status);
+ ((UpgradePreCheckOutputBuilder)outObj).setPayload(payload);
+ return outObj;
+ case AttachVolume:
+ outObj = new AttachVolumeOutputBuilder();
+ ((AttachVolumeOutputBuilder)outObj).setCommonHeader(commonHeader);
+ ((AttachVolumeOutputBuilder)outObj).setStatus(status);
+ return outObj;
+ case DetachVolume:
+ outObj = new DetachVolumeOutputBuilder();
+ ((DetachVolumeOutputBuilder)outObj).setCommonHeader(commonHeader);
+ ((DetachVolumeOutputBuilder)outObj).setStatus(status);
+ return outObj;
default:
throw new IllegalArgumentException(action+" action is not supported");
}
try {
ObjectMapper objectMapper = new ObjectMapper();
payloadAsString = objectMapper.writeValueAsString(inObj);
-// payloadAsString = objectMapper.writeValueAsString(payloadAsString);
} catch (JsonProcessingException e) {
String errMsg = "Error serialize payload json to string";
throw new ParseException(errMsg + "-" + e.toString(), 0);
}
CommonHeaderBuilder commonHeaderBuilder = new CommonHeaderBuilder();
- org.opendaylight.yang.gen.v1.org.onap.appc.lcm.rev160108.common.header.common.header.Flags commonHeaderFlags = null;
+ org.opendaylight.yang.gen.v1.org.onap.appc.lcm.rev160108.common.header.common.header.Flags commonHeaderFlags;
if(inObj.getCommonHeader().getFlags() != null){
commonHeaderFlags = Converter.convFlagsMapTorev160108Flags(inObj.getCommonHeader().getFlags());
commonHeaderBuilder.setFlags(commonHeaderFlags);
}
if(inObj.getCommonHeader().getTimeStamp() != null){
- String zuluTimestampStr = Converter.convDateToZuluString(Date.from(inObj.getCommonHeader().getTimeStamp()));
+ String zuluTimestampStr = Converter.convDateToZuluString(inObj.getCommonHeader().getTimeStamp());
ZULU zuluTimestamp = new ZULU(zuluTimestampStr);
commonHeaderBuilder.setTimestamp(zuluTimestamp);
}
public static org.opendaylight.yang.gen.v1.org.onap.appc.lcm.rev160108.common.header.common.header.Flags
convFlagsMapTorev160108Flags(org.onap.appc.domainmodel.lcm.Flags flags) {
- Flags rev160108flags = null;
+ Flags rev160108flags;
boolean anyFlag = false;
FlagsBuilder flagsBuilder = new FlagsBuilder();
/*
objectMapper.addMixInAnnotations(Payload.class, MixIn.class);
objectMapper.addMixInAnnotations(ZULU.class, MixIn.class);
-// .configure(SerializationConfig.Feature.SORT_PROPERTIES_ALPHABETICALLY,true)
+// .configure(SerializationConfig.Feature.SORT_PROPERTIES_ALPHABETICALLY,true)
ObjectWriter writer = objectMapper.setSerializationInclusion(JsonInclude.Include.NON_NULL).configure(MapperFeature.SORT_PROPERTIES_ALPHABETICALLY,true)
.writer(SerializationFeature.WRAP_ROOT_VALUE).withRootName(DMaaP_ROOT_VALUE).withoutFeatures(SerializationFeature.ORDER_MAP_ENTRIES_BY_KEYS);
return writer.writeValueAsString(message);
objectMapper.addMixInAnnotations(Payload.class, MixIn.class);
objectMapper.addMixInAnnotations(ZULU.class, MixIn.class);
-// .configure(SerializationConfig.Feature.SORT_PROPERTIES_ALPHABETICALLY,true)
+// .configure(SerializationConfig.Feature.SORT_PROPERTIES_ALPHABETICALLY,true)
ObjectWriter writer = objectMapper.setSerializationInclusion(JsonInclude.Include.NON_NULL).configure(MapperFeature.SORT_PROPERTIES_ALPHABETICALLY,true).writer();
return writer.writeValueAsString(dmaapOutgoingMessage);
}