Add modify vnf feature on driver
[vfc/nfvo/driver/vnfm/svnfm.git] / nokia / vnfmdriver / vfcadaptorservice / vfcadaptor / src / main / java / org / onap / vfc / nfvo / driver / vnfm / svnfm / http / client / HttpRequestProcessor.java
index 363b5a9..c553238 100644 (file)
@@ -22,17 +22,21 @@ import java.net.URI;
 import org.apache.http.HttpEntity;
 import org.apache.http.HttpResponse;
 import org.apache.http.client.ClientProtocolException;
+import org.apache.http.client.methods.HttpPatch;
 import org.apache.http.client.methods.HttpPost;
 import org.apache.http.client.methods.HttpRequestBase;
-import org.apache.http.entity.StringEntity;
 import org.apache.http.entity.ByteArrayEntity;
+import org.apache.http.entity.StringEntity;
 import org.apache.http.impl.client.CloseableHttpClient;
 import org.apache.http.impl.client.HttpClientBuilder;
 import org.apache.http.util.EntityUtils;
 import org.onap.vfc.nfvo.driver.vnfm.svnfm.constant.CommonConstants;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.web.bind.annotation.RequestMethod;
 
 public class HttpRequestProcessor {
+       private static final Logger logger = LoggerFactory.getLogger(HttpRequestProcessor.class);
        private CloseableHttpClient httpClient;
        private HttpRequestBase httpRequest;
        
@@ -47,7 +51,8 @@ public class HttpRequestProcessor {
                httpRequest.setURI(URI.create(url));
                
                HttpResponse response = httpClient.execute(httpRequest);
-               
+               httpRequest.releaseConnection();
+//             httpClient.close();
                HttpResult httpResult = buildHttpResult(response);
                
                return httpResult;
@@ -76,7 +81,11 @@ public class HttpRequestProcessor {
        }
 
        public void addPostEntity(String bodyStr) {
-               ((HttpPost)httpRequest).setEntity(new StringEntity(bodyStr, CommonConstants.UTF_8));
+               if(httpRequest instanceof HttpPost) {
+                       ((HttpPost)httpRequest).setEntity(new StringEntity(bodyStr, CommonConstants.UTF_8));
+               } else if(httpRequest instanceof HttpPatch) {
+                       ((HttpPatch)httpRequest).setEntity(new StringEntity(bodyStr, CommonConstants.UTF_8));
+               }
        }
        
        public void addBytesPostEntity(byte[] byteArray) {