- protected Response delete(String packageName) throws IOException {\r
- Client client = createClient();\r
- WebTarget webTarget = client\r
- .target(MicroServiceConfig.getMsbServerAddrWithHttpPrefix() + RuleMgtConstant.ENGINE_PATH + "/" + packageName);\r
- return webTarget.request(MediaType.APPLICATION_JSON).delete();\r
+ private static final String PREFIX = "https://";\r
+ private static final String PORT = ":9102";\r
+\r
+ protected HttpResponse delete(String packageName, String ip) throws Exception {\r
+ HashMap headers = createHeaders();\r
+ String url = PREFIX + ip + PORT + RuleMgtConstant.ENGINE_PATH + "/" + packageName;\r
+ CloseableHttpClient httpClient = null;\r
+ try {\r
+ httpClient = HttpsUtils.getHttpClient(HttpsUtils.DEFUALT_TIMEOUT);\r
+ return HttpsUtils.delete(url, headers, httpClient);\r
+ } finally {\r
+ closeHttpClient(httpClient);\r
+ }\r
+ }\r
+\r
+ protected HttpResponse check(CorrelationCheckRule4Engine correlationCheckRule4Engine, String ip)\r
+ throws Exception {\r
+ String content = GsonUtil.beanToJson(correlationCheckRule4Engine);\r
+ HashMap headers = createHeaders();\r
+ String url = PREFIX + ip + PORT + RuleMgtConstant.ENGINE_PATH;\r
+ CloseableHttpClient httpClient = null;\r
+ try {\r
+ httpClient = HttpsUtils.getHttpClient(HttpsUtils.DEFUALT_TIMEOUT);\r
+ return HttpsUtils.post(url, headers, new HashMap<>(), new StringEntity(content), httpClient);\r
+ } finally {\r
+ closeHttpClient(httpClient);\r
+ }\r