fix: 修复 prometheus reload 请求method错误

2 files changed, 4 insertions, 2 deletions

diff --git a/src/main/java/net/geedge/confagent/controller/BaseController.java b/src/main/java/net/geedge/confagent/controller/BaseController.java
index 822fe17..a92f204 100644
--- a/src/main/java/net/geedge/confagent/controller/BaseController.java
+++ b/src/main/java/net/geedge/confagent/controller/BaseController.java
@@ -2,6 +2,7 @@ package net.geedge.confagent.controller;
 
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
+import org.springframework.http.HttpEntity;
 import org.springframework.http.ResponseEntity;
 import org.springframework.web.client.RestTemplate;
 
@@ -77,7 +78,7 @@ public abstract class BaseController {
 	 */
 	public boolean reloadServerConfiguration(int serverPort, String defaultServerIP) {
 		String url = String.format("http://%s:%s%s", defaultServerIP,serverPort,"/-/reload");
-		ResponseEntity<String> responseEntity = restTemplate.getForEntity(url, String.class);
+		ResponseEntity<String> responseEntity = restTemplate.postForEntity(url, HttpEntity.EMPTY, String.class);
 		log.info("request statusCode: {}", responseEntity.getStatusCode());
 		if (log.isDebugEnabled()) {
 			log.debug("request result: {}", responseEntity.getBody());
diff --git a/src/main/java/net/geedge/confagent/controller/PrometheusController.java b/src/main/java/net/geedge/confagent/controller/PrometheusController.java
index 1db0fc1..0521638 100644
--- a/src/main/java/net/geedge/confagent/controller/PrometheusController.java
+++ b/src/main/java/net/geedge/confagent/controller/PrometheusController.java
@@ -19,6 +19,7 @@ import javax.servlet.http.HttpServletResponse;
 
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
+import org.springframework.http.HttpEntity;
 import org.springframework.http.ResponseEntity;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.PostMapping;
@@ -256,7 +257,7 @@ public class PrometheusController extends BaseController{
         int prometheusPort = ObjectUtil.defaultIfNull(ConfagentUtil.prometheusPortInMemory, DEFAULT_PROMETHEUS_PORT);
         String url = String.format("http://%s:%s%s", defaultPrometheusIP,prometheusPort,"/-/reload");
         log.debug("reload url: {}",url);
-        ResponseEntity<String> responseEntity = restTemplate.getForEntity(url, String.class);
+        ResponseEntity<String> responseEntity = restTemplate.postForEntity(url, HttpEntity.EMPTY, String.class);
         return responseEntity.getStatusCode().is2xxSuccessful();
     }