fix 201 bug

Author: syswu

pom.xml

@@ -5,7 +5,7 @@
 
 	<groupId>io.github.kubesys</groupId>
 	<artifactId>client-java</artifactId>
-	<version>1.0.3</version>
+	<version>1.0.4</version>
 	<packaging>jar</packaging>
 
 	<name>client-java</name>

src/main/java/io/github/kubesys/client/KubernetesClient.java

@@ -58,6 +58,7 @@
 
 import com.fasterxml.jackson.databind.JsonNode;
 import com.fasterxml.jackson.databind.ObjectMapper;
+import com.fasterxml.jackson.databind.SerializationFeature;
 import com.fasterxml.jackson.databind.node.ArrayNode;
 import com.fasterxml.jackson.databind.node.ObjectNode;
 import com.fasterxml.jackson.dataformat.yaml.YAMLFactory;
@@ -1617,15 +1618,20 @@ protected synchronized JsonNode parseResponse(CloseableHttpResponse response) {
 			switch (response.getCode()) {
 				case 200:
 				try {
-					return new ObjectMapper().readTree(response.getEntity().getContent());
+					ObjectMapper objectMapper = new ObjectMapper();
+					objectMapper.disable(SerializationFeature.FAIL_ON_EMPTY_BEANS);
+					return objectMapper.readTree(response.getEntity().getContent());
 				} catch (Exception e) {
 					throw new KubernetesUnknownException(e.toString());
 				} 
-//					if (result.has("status") && result.get("status").asText().equals("Failure")) {
-//						int code = result.get("code").asInt();
-//						String cause = statusDesc.get(code);
-//						throw new Exception(cause != null ? cause : result.toPrettyString());
-//					}
+				case 201:
+					try {
+						ObjectMapper objectMapper = new ObjectMapper();
+						objectMapper.disable(SerializationFeature.FAIL_ON_EMPTY_BEANS);
+						return objectMapper.readTree(response.getEntity().getContent());
+					} catch (Exception e) {
+						throw new KubernetesUnknownException(e.toString());
+					} 
 				case 400:
 					throw new KubernetesBadRequestException(response.toString());
 				case 401:

src/test/java/io/github/kubesys/client/install/stack/KubeMessageTest.java

@@ -52,6 +52,7 @@ public static void main(String[] args) throws Exception {
 										new Env("RABBITMQ_DEFAULT_PASS", new ValueFrom(
 												new SecretKeyRef(NAME, StackCommon.CONFIG_PASSWORD)))}, 
 								new Port[] {
+										new Port(15674),
 										new Port(15672),
 										new Port(5672)
 								}, 
@@ -65,6 +66,7 @@ public static void main(String[] args) throws Exception {
 		service.withType("NodePort").withSelector(NAME)
 				.withPort(15672, 30305, "management")
 				.withPort(5672, 30304, "rabbitmq")
+				.withPort(15674, 30303, "web")
 		.stream(System.out);
 	}
 }