summaryrefslogtreecommitdiffstats
path: root/appc-event-listener/appc-event-listener-bundle/src/main/java/org
diff options
context:
space:
mode:
authorJoss Armstrong <joss.armstrong@ericsson.com>2019-02-20 10:06:54 +0000
committerTakamune Cho <takamune.cho@att.com>2019-02-21 15:00:55 +0000
commit80488f2e675692e7c5339c94f3c5aefe5f533b44 (patch)
tree5cf1e0e6020b145c1a5f3fb82f7086624ddb9bfb /appc-event-listener/appc-event-listener-bundle/src/main/java/org
parent70ed737df023f8d15067c1f59e9818257b271f87 (diff)
Test coverage in OutgoingMessage
Increased coverage to 100% Issue-ID: APPC-1462 Change-Id: I4b2646da01c20e9095c617d1f82c78fae30f2418 Signed-off-by: Joss Armstrong <joss.armstrong@ericsson.com>
Diffstat (limited to 'appc-event-listener/appc-event-listener-bundle/src/main/java/org')
-rw-r--r--appc-event-listener/appc-event-listener-bundle/src/main/java/org/onap/appc/listener/demo/model/OutgoingMessage.java193
1 files changed, 100 insertions, 93 deletions
diff --git a/appc-event-listener/appc-event-listener-bundle/src/main/java/org/onap/appc/listener/demo/model/OutgoingMessage.java b/appc-event-listener/appc-event-listener-bundle/src/main/java/org/onap/appc/listener/demo/model/OutgoingMessage.java
index a2417ed0c..375dde55f 100644
--- a/appc-event-listener/appc-event-listener-bundle/src/main/java/org/onap/appc/listener/demo/model/OutgoingMessage.java
+++ b/appc-event-listener/appc-event-listener-bundle/src/main/java/org/onap/appc/listener/demo/model/OutgoingMessage.java
@@ -5,6 +5,8 @@
* Copyright (C) 2017-2018 AT&T Intellectual Property. All rights reserved.
* ================================================================================
* Copyright (C) 2017 Amdocs
+ * ================================================================================
+ * Modifications Copyright (C) 2019 Ericsson
* =============================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@@ -24,6 +26,7 @@
package org.onap.appc.listener.demo.model;
import java.net.InetAddress;
+import java.net.UnknownHostException;
import java.security.SecureRandom;
import java.text.SimpleDateFormat;
import java.util.Date;
@@ -51,20 +54,20 @@ public class OutgoingMessage extends CommonMessage {
}
public OutgoingMessage(IncomingMessage msg) {
- setHeader(msg.getHeader());
- setPayload(msg.getPayload());
-// setId(msg.getId());
-// setOriginalRequest(msg.getRequest());
-// setRequestClient(msg.getRequestClient());
-// setRequestTime(msg.getRequestTime());
-// setVmName(msg.getVmName());
-// setFromSystem(generateFrom());
-// setResponse(Status.PENDING);
-// setPolicyName(msg.getPolicyName());
-// setPolicyVersion(msg.getPolicyVersion());
-// setStartTime(msg.getStartTime());
+ setHeader(msg.getHeader());
+ setPayload(msg.getPayload());
+ // setId(msg.getId());
+ // setOriginalRequest(msg.getRequest());
+ // setRequestClient(msg.getRequestClient());
+ // setRequestTime(msg.getRequestTime());
+ // setVmName(msg.getVmName());
+ // setFromSystem(generateFrom());
+ // setResponse(Status.PENDING);
+ // setPolicyName(msg.getPolicyName());
+ // setPolicyVersion(msg.getPolicyVersion());
+ // setStartTime(msg.getStartTime());
}
-
+
private static final long serialVersionUID = -5447940920271469613L;
/*
* The status of the response
@@ -73,20 +76,20 @@ public class OutgoingMessage extends CommonMessage {
private OutStatus status;
/**
- * @return the status
- */
- public OutStatus getStatus() {
- return status;
- }
-
- /**
- * @param status the status to set
- */
- public void setStatus(OutStatus status) {
- this.status = status;
- }
-
- public void updateResponseTime() {
+ * @return the status
+ */
+ public OutStatus getStatus() {
+ return status;
+ }
+
+ /**
+ * @param status the status to set
+ */
+ public void setStatus(OutStatus status) {
+ this.status = status;
+ }
+
+ public void updateResponseTime() {
SecureRandom rand = new SecureRandom();
SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd kk:mm:ss.SSS");
df.setTimeZone(TimeZone.getTimeZone("UTC"));
@@ -97,7 +100,7 @@ public class OutgoingMessage extends CommonMessage {
public String generateFrom() {
String name;
try {
- InetAddress iAddress = InetAddress.getLocalHost();
+ InetAddress iAddress = getLocalHost();
name = iAddress.getCanonicalHostName();
} catch (Exception e) {
// Could not get anything from the InetAddress
@@ -122,72 +125,76 @@ public class OutgoingMessage extends CommonMessage {
return json;
}
-// @Override
-// public String toString() {
-// return String.format("%s - %s", getId(), getResponse());
-// }
-
+ // @Override
+ // public String toString() {
+ // return String.format("%s - %s", getId(), getResponse());
+ // }
+
public static class OutStatus{
- @JsonProperty("Code")
- private String code;
-
- @JsonProperty("Value")
- private String value;
-
- /**
- * @return the code
- */
- public String getCode() {
- return code;
- }
-
- /**
- * @param code the code to set
- */
- public void setCode(String code) {
- this.code = code;
- }
-
- /**
- * @return the value
- */
- public String getValue() {
- return value;
- }
-
- /**
- * @param value the value to set
- */
- public void setValue(String value) {
- this.value = value;
- }
-
+ @JsonProperty("Code")
+ private String code;
+
+ @JsonProperty("Value")
+ private String value;
+
+ /**
+ * @return the code
+ */
+ public String getCode() {
+ return code;
+ }
+
+ /**
+ * @param code the code to set
+ */
+ public void setCode(String code) {
+ this.code = code;
+ }
+
+ /**
+ * @return the value
+ */
+ public String getValue() {
+ return value;
+ }
+
+ /**
+ * @param value the value to set
+ */
+ public void setValue(String value) {
+ this.value = value;
+ }
+
+ }
+
+ public void setResponse(Status newStatus) {
+ if(this.status == null){
+ this.status = new OutStatus();
+ return;
+ }
+
+ switch (newStatus){
+ case ACCEPTED:
+ this.status.setValue(newStatus.getValue());
+ this.status.setCode("100");
+ break;
+
+ case FAILURE:
+ this.status.setValue(newStatus.getValue());
+ this.status.setCode("500");
+ break;
+
+ case SUCCESS:
+ this.status.setValue(newStatus.getValue());
+ this.status.setCode("400");
+ break;
+ default:
+ break;
+
+ }
}
- public void setResponse(Status newStatus) {
- if(this.status == null){
- this.status = new OutStatus();
- }
-
- switch (newStatus){
- case ACCEPTED:
- this.status.setValue(newStatus.getValue());
- this.status.setCode("100");
- break;
-
- case FAILURE:
- this.status.setValue(newStatus.getValue());
- this.status.setCode("500");
- break;
-
- case SUCCESS:
- this.status.setValue(newStatus.getValue());
- this.status.setCode("400");
- break;
- default:
- break;
-
- }
-
- }
+ protected InetAddress getLocalHost() throws UnknownHostException {
+ return InetAddress.getLocalHost();
+ }
}