From 79f626b0c4419dfcb5b7d1ea0a279a523c6c21bd Mon Sep 17 00:00:00 2001 From: liboNet Date: Sat, 25 May 2019 05:32:49 +0800 Subject: [PATCH] Fix port mismatch and return value judgement issue . the port of k8s plugin has changed from 8081 to 9015 . the value from 200 to 300 is acceptable from k8s plugin Change-Id: I85c61d2275c7913f8c8dbeee0751349552bec29d Issue-ID: MULTICLOUD-650 Signed-off-by: liboNet --- .../distribution/forwarding/k8s/K8sArtifactForwarder.java | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/artifactbroker/plugins/forwarding-plugins/src/main/java/org/onap/policy/distribution/forwarding/k8s/K8sArtifactForwarder.java b/artifactbroker/plugins/forwarding-plugins/src/main/java/org/onap/policy/distribution/forwarding/k8s/K8sArtifactForwarder.java index d920907..9bfe264 100644 --- a/artifactbroker/plugins/forwarding-plugins/src/main/java/org/onap/policy/distribution/forwarding/k8s/K8sArtifactForwarder.java +++ b/artifactbroker/plugins/forwarding-plugins/src/main/java/org/onap/policy/distribution/forwarding/k8s/K8sArtifactForwarder.java @@ -64,7 +64,7 @@ import org.onap.sdc.api.notification.IArtifactInfo; public class K8sArtifactForwarder implements ArtifactForwarder { private static final Logger LOGGER = FlexLogger.getLogger(K8sArtifactForwarder.class); - private static final String BASE_PATH = "http://localhost:8081/v1/rb/definition"; + private static final String BASE_PATH = "http://localhost:9015/v1/rb/definition"; private static final String CLOUD_TECHNOLOGY_SPECIFIC_ARTIFACT = "CLOUD_TECHNOLOGY_SPECIFIC_ARTIFACT"; private Map artifactMap; @@ -184,10 +184,12 @@ public class K8sArtifactForwarder implements ArtifactForwarder { String result = EntityUtils.toString(closeableHttpResponse.getEntity()); System.out.println("result = {}" + result); System.out.println("status = {}" + closeableHttpResponse.getStatusLine().getStatusCode()); - if ( closeableHttpResponse.getStatusLine().getStatusCode() != 200 ) { - System.out.println("exception: ret= " + closeableHttpResponse.getStatusLine().getStatusCode()); - } else { + int status = closeableHttpResponse.getStatusLine().getStatusCode(); + // [200, 300] means pass + if ( (status >=200) && (status <= 300) ) { ret = true; + } else { + System.out.println("exception: ret= " + status); } closeableHttpResponse.close(); -- 2.16.6