Bug 35126384 - Build: management.MultiClusterInSingleProcessTests.xtestClusterNodeShutdownWithServicesRestart (14.1.1.0 -> ce-v14.1.1.0, 12.2.1.4 @99177)

[git-p4: depot-paths = "//dev/coherence-ce/release/coherence-ce-v14.1.1.0/": change = 99183]

Author: lsho

prj/test/functional/management/src/test/java/management/shutdown/ManagementShutdownTests.java

@@ -208,9 +208,32 @@ public void testClusterNodeShutdownWithServicesRestart()
         assertThat(listItemMaps.get(0).get("member"), is(memberName));
         assertThat(listItemMaps.get(0).get("running"), is(true));
 
+        target = getBaseTarget().path(SERVICES).path(HttpHelper.getServiceName()).path("members");
+        response = target.request().get();
+        assertThat(response.getStatus(), is(Response.Status.OK.getStatusCode()));
+        mapResponse = readEntity(target, response);
+        listItemMaps = (List<Map>) mapResponse.get("items");
+        assertThat(listItemMaps.size(), is(1));
+
+        String sNodeId = (String) listItemMaps.get(0).get("nodeId");
         CacheFactory.log("Shutting down " + memberName, CacheFactory.LOG_INFO);
-        response = getBaseTarget().path("members").path(memberName).path("shutdown").request(MediaType.APPLICATION_JSON_TYPE).post(null);
-        MatcherAssert.assertThat(response.getStatus(), is(Response.Status.OK.getStatusCode()));
+        try
+            {
+            response = getBaseTarget().path("members").path(SERVER_PREFIX + "-2").path("shutdown").request(MediaType.APPLICATION_JSON_TYPE).post(null);
+            MatcherAssert.assertThat(response.getStatus(), is(Response.Status.OK.getStatusCode()));
+            }
+        catch (Exception e)
+            {
+            // Occasionally, it may get exception if the management HTTP service
+            // is started on the node being shutdown;
+            // In this case, it won't be able to connect to the REST service again;
+            // log the exception and return.
+            System.err.println("xtestClusterNodeShutdownWithServicesRestart() got an exception: " + e);
+            if (sNodeId.equals("2"))
+                {
+                return;
+                }
+            }
 
         AtomicReference<Response> serviceMemberResponse = new AtomicReference<>();
         WebTarget serviceMemberTarget = getBaseTarget().path(SERVICES).path(MetricsHttpHelper.getServiceName()).path("members");