diff options
author | 2017-08-08 14:02:53 +0800 | |
---|---|---|
committer | 2017-08-08 14:02:53 +0800 | |
commit | c0604184b2aa8cff924ca783ec6b36f1f5988775 (patch) | |
tree | 1c70ffe1ad90c915b3382a37eb2fa80901519c7b /wso2bpel-ext/wso2bpel-core/wso2bpel-mgr/src/main/java/org/openo/carbon/bpel/resources/BpsPackage.java | |
parent | 706fc9fed496972968fde136c3e4e10f9578a5b3 (diff) |
init code
Change-Id: Icd0948118397b256da70dfbcbbec5520dc5eafd4
Signed-off-by: Zhaoxing <meng.zhaoxing1@zte.com.cn>
Diffstat (limited to 'wso2bpel-ext/wso2bpel-core/wso2bpel-mgr/src/main/java/org/openo/carbon/bpel/resources/BpsPackage.java')
-rw-r--r-- | wso2bpel-ext/wso2bpel-core/wso2bpel-mgr/src/main/java/org/openo/carbon/bpel/resources/BpsPackage.java | 632 |
1 files changed, 0 insertions, 632 deletions
diff --git a/wso2bpel-ext/wso2bpel-core/wso2bpel-mgr/src/main/java/org/openo/carbon/bpel/resources/BpsPackage.java b/wso2bpel-ext/wso2bpel-core/wso2bpel-mgr/src/main/java/org/openo/carbon/bpel/resources/BpsPackage.java deleted file mode 100644 index e11c1eb..0000000 --- a/wso2bpel-ext/wso2bpel-core/wso2bpel-mgr/src/main/java/org/openo/carbon/bpel/resources/BpsPackage.java +++ /dev/null @@ -1,632 +0,0 @@ -/** - * Copyright 2016-2017 ZTE Corporation. - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.openo.carbon.bpel.resources; - -import java.io.File; -import java.io.IOException; -import java.io.InputStream; -import java.util.ArrayList; -import java.util.HashMap; -import java.util.HashSet; -import java.util.Iterator; -import java.util.LinkedHashMap; -import java.util.List; -import java.util.Map; -import java.util.Set; -import java.util.concurrent.atomic.AtomicLong; - -import javax.activation.DataHandler; -import javax.activation.DataSource; -import javax.activation.FileDataSource; -import javax.servlet.http.HttpServletRequest; -import javax.servlet.http.HttpServletResponse; -import javax.ws.rs.QueryParam; -import javax.ws.rs.Consumes; -import javax.ws.rs.DELETE; -import javax.ws.rs.GET; -import javax.ws.rs.POST; -import javax.ws.rs.Path; -import javax.ws.rs.PathParam; -import javax.ws.rs.Produces; -import javax.ws.rs.client.Client; -import javax.ws.rs.client.ClientBuilder; -import javax.ws.rs.client.Entity; -import javax.ws.rs.client.WebTarget; -import javax.ws.rs.core.Context; -import javax.ws.rs.core.MediaType; -import javax.xml.namespace.QName; - -import org.apache.axiom.om.OMAbstractFactory; -import org.apache.axiom.om.OMElement; -import org.apache.axiom.om.OMFactory; -import org.apache.axiom.om.OMNamespace; -import org.apache.axis2.AxisFault; -import org.apache.axis2.addressing.EndpointReference; -import org.apache.axis2.client.Options; -import org.apache.axis2.rpc.client.RPCServiceClient; -import org.apache.axis2.transport.http.HTTPConstants; -import org.apache.axis2.transport.http.HttpTransportProperties; -import org.apache.axis2.transport.http.HttpTransportProperties.Authenticator; -import org.apache.commons.io.FileUtils; -import org.apache.commons.logging.Log; -import org.apache.commons.logging.LogFactory; -import org.glassfish.jersey.media.multipart.FormDataContentDisposition; -import org.glassfish.jersey.media.multipart.FormDataMultiPart; -import org.glassfish.jersey.media.multipart.FormDataParam; -import org.glassfish.jersey.media.multipart.MultiPartFeature; -import org.glassfish.jersey.media.multipart.file.FileDataBodyPart; -import org.wso2.carbon.bpel.stub.upload.types.UploadedFileItem; -import org.openo.carbon.bpel.common.Config; -import org.openo.carbon.bpel.util.JsonUtil; -import org.openo.carbon.bpel.util.Xml2JsonUtil; - -import com.codahale.metrics.annotation.Timed; -import com.fasterxml.jackson.core.JsonParseException; -import com.fasterxml.jackson.databind.JsonMappingException; - -import io.swagger.annotations.Api; -import io.swagger.annotations.ApiOperation; - -@Path("/") -@Api(tags = {"wso2 bpel api"}) -public class BpsPackage { - - private static final Log log = LogFactory.getLog(BpsPackage.class); - - public static final int STATUS_SUCCESS = 1; - public static final int STATUS_FAIL = 0; - /** - * 无错误 - */ - public static final int ERROR_CODE_NOERROR = 0; - /** - * 不支持的文件类型 - */ - public static final int ERROR_CODE_PACKAGE_UNSUPPORED_FILE = 10001; - /** - * 同名的包正在操作中 - */ - public static final int ERROR_CODE_PACKAGE_STATUS_BUSY = 10002; - /** - * 包名重复 - */ - public static final int ERROR_CODE_PACKAGE_DUPLICATED_NAME = 10003; - /** - * 未获取到包部署的信息 - */ - public static final int ERROR_CODE_PACKAGE_DEPLOY_INFORMATION_IS_LOST = 10004; - /** - * 卸载包失败 - */ - public static final int ERROR_CODE_PACKAGE_UNDEPLOY_FAILED = 10005; - /** - * 包不存在 - */ - public static final int ERROR_CODE_PACKAGE_NOTEXISTS = 10006; - /** - * 服务运行时异常 - */ - public static final int ERROR_CODE_RUNTIME_EXCEPTION = 20001; - /** - * Axis运行时异常 - */ - public static final int ERROR_CODE_RUNTIME_EXCEPTION_AXIS = 20002; - /** - * IO运行时异常 - */ - public static final int ERROR_CODE_RUNTIME_EXCEPTION_IO = 20003; - - public static Set<String> packageNameSet = new HashSet<String>(); - - private Map<String, String> configMap = null; - - @SuppressWarnings("unused") - private final AtomicLong counter; - - public BpsPackage() { - this.counter = new AtomicLong(); - } - - private synchronized String getConfig(String key) { - if (configMap == null) { - configMap = new HashMap<String, String>(); - String uploadFilePath = Config.getConfigration().getWso2UploadFilePath(); - String jksFile = Config.getConfigration().getWso2SslJksFile(); - String trustStorePassword = Config.getConfigration().getWso2SslJksPassword(); - String httpUsername = Config.getConfigration().getWso2AuthUserName(); - String httpPassword = Config.getConfigration().getWso2AuthPassword(); - String host = Config.getConfigration().getWso2Host(); - String port = Config.getConfigration().getWso2HostPort(); - configMap.put("uploadFilePath", uploadFilePath); - configMap.put("jksFile", jksFile); - configMap.put("trustStorePassword", trustStorePassword); - configMap.put("httpUsername", httpUsername); - configMap.put("httpPassword", httpPassword); - configMap.put("host", host); - configMap.put("port", port); - } - if (configMap.containsKey(key)) { - return configMap.get(key); - } else { - return ""; - } - } - - public static boolean lockPackageName(String packageName) { - boolean succeed = false; - synchronized (packageNameSet) { - if (!packageNameSet.contains(packageName)) { - packageNameSet.add(packageName); - succeed = true; - } - } - return succeed; - } - - public static boolean unlockPackageName(String packageName) { - boolean succeed = false; - synchronized (packageNameSet) { - if (packageNameSet.contains(packageName)) { - packageNameSet.remove(packageName); - succeed = true; - } - } - return succeed; - } - - @POST - @Path(value = "package") - @Consumes(MediaType.MULTIPART_FORM_DATA) - @Produces(value = MediaType.APPLICATION_JSON) - @ApiOperation(value = "package process", response = Map.class) - @Timed - public Map<String, Object> uploadFile(@FormDataParam("filename") String filename, - @FormDataParam("file") InputStream fileInputStream, - @FormDataParam("file") FormDataContentDisposition fileDetail, - @Context HttpServletRequest request, @Context HttpServletResponse response) - throws IOException { - Map<String, Object> map = new LinkedHashMap<String, Object>(); - String errorMessage = "unkown"; - int errorCode = ERROR_CODE_NOERROR; - - String fileName = fileDetail.getFileName(); - String fullName = getConfig("uploadFilePath") + "/" + fileName; - File file = new File(fullName); - String packageName = null; - try { - if (fileName.endsWith(".zip")) { - packageName = fileName.substring(0, fileName.length() - 4); - } else { - errorCode = ERROR_CODE_PACKAGE_UNSUPPORED_FILE; - throw new Exception("Only support *.zip file."); - } - if (!lockPackageName(packageName)) { - errorCode = ERROR_CODE_PACKAGE_STATUS_BUSY; - throw new Exception("Package " + packageName + " is operating."); - } - FileUtils.copyInputStreamToFile(fileInputStream, file); - System.setProperty("javax.net.ssl.trustStore", "*.keystore"); - System.setProperty("java.protocol.handler.pkgs", "com.sun.net.ssl.internal.www.protocol"); - System.setProperty("javax.net.ssl.trustStore", getConfig("jksFile")); - System.setProperty("javax.net.ssl.trustStorePassword", getConfig("trustStorePassword")); - - HttpTransportProperties.Authenticator authenticator = - new HttpTransportProperties.Authenticator(); - List<String> auth = new ArrayList<String>(); - auth.add(Authenticator.BASIC); - authenticator.setAuthSchemes(auth); - authenticator.setUsername(getConfig("httpUsername")); - authenticator.setPassword(getConfig("httpPassword")); - authenticator.setPreemptiveAuthentication(true); - - map.putAll(bpsDeployPackage(fileName, fullName, packageName, authenticator)); - map.put("status", STATUS_SUCCESS); - map.put("message", "success"); - return map; - } catch (AxisFault e) { - errorMessage = e.getLocalizedMessage(); - errorCode = ERROR_CODE_RUNTIME_EXCEPTION_AXIS; - log.error(e.getMessage(), e); - e.printStackTrace(); - } catch (IOException e) { - errorMessage = e.getLocalizedMessage(); - errorCode = ERROR_CODE_RUNTIME_EXCEPTION_IO; - log.error(e.getMessage(), e); - e.printStackTrace(); - } catch (Throwable e) { - errorMessage = e.getLocalizedMessage(); - if (e instanceof BpsServiceException) { - errorCode = ((BpsServiceException) e).getErrorCode(); - } else { - errorCode = ERROR_CODE_RUNTIME_EXCEPTION; - } - log.error(e.getMessage(), e); - e.printStackTrace(); - } finally { - if (packageName != null) { - unlockPackageName(packageName); - } - } - map.put("errorCode", errorCode); - map.put("status", STATUS_FAIL); - map.put("message", errorMessage); - return map; - } - - @SuppressWarnings("rawtypes") - private Map<String, Object> bpsDeployPackage(String fileName, String fullName, String packageName, - HttpTransportProperties.Authenticator authenticator) - throws JsonParseException, JsonMappingException, IOException, AxisFault, Exception { - Map<String, Object> map = new HashMap<String, Object>(); - Map deployedPackageInfoMap = getDeployedPackageInfo(authenticator, packageName, ""); - if (deployedPackageInfoMap.get("packageName") != null) { - throw new BpsServiceException(ERROR_CODE_PACKAGE_DUPLICATED_NAME,"Package " + deployedPackageInfoMap.get("packageName") - + " exist, please undeploy it first."); - } - OMElement element = deployPackage(fileName, fullName, authenticator); - System.out.println(Xml2JsonUtil.xml2JSON(element.toString())); - - long timeout = 60 * 1000L; - long timeStart = System.currentTimeMillis(); - while (System.currentTimeMillis() - timeStart < timeout) { - deployedPackageInfoMap = getDeployedPackageInfo(authenticator, packageName, ""); - if (deployedPackageInfoMap.get("packageName") == null) { - Thread.sleep(2000); - } else { - break; - } - } - if (deployedPackageInfoMap.get("packageName") == null) { - throw new BpsServiceException(ERROR_CODE_PACKAGE_DEPLOY_INFORMATION_IS_LOST, - "Package " + packageName + " deploy failed or deploy information is lost."); - } - map.put("packageName", deployedPackageInfoMap.get("packageName")); - map.put("processId", deployedPackageInfoMap.get("pid")); - return map; - } - - private OMElement deployPackage(String fileName, String fullName, - HttpTransportProperties.Authenticator authenticator) throws AxisFault { - String url = - "https://" + getConfig("host") + ":" + getConfig("port") + "/services/BPELUploader?wsdl"; - RPCServiceClient serviceClient = new RPCServiceClient(); - EndpointReference targetEPR = new EndpointReference(url); - Options options = serviceClient.getOptions(); - options.setTo(targetEPR); - options.setAction("urn:uploadService"); - options.setProperty(HTTPConstants.SO_TIMEOUT, new Integer(300000)); - options.setProperty(HTTPConstants.AUTHENTICATE, authenticator); - serviceClient.setOptions(options); - - QName qname = new QName("http://services.deployer.bpel.carbon.wso2.org", "uploadService"); - UploadedFileItem fileItem = new UploadedFileItem(); - fileItem.setFileName(fileName); - fileItem.setFileType("zip"); - - DataSource dataSource = new FileDataSource(fullName); - fileItem.setDataHandler(new DataHandler(dataSource)); - UploadedFileItem[] parameters = new UploadedFileItem[] {fileItem}; - OMElement element = serviceClient.invokeBlocking(qname, parameters); - return element; - } - - @Path(value = "package/{packageName}") - @DELETE - @Produces(value = MediaType.APPLICATION_JSON) - @ApiOperation(value = "delete", response = Map.class) - @Timed - public Map<String, Object> delete(@PathParam("packageName") String packageName, - @Context HttpServletRequest request) { - Map<String, Object> map = new LinkedHashMap<String, Object>(); - String errorMessage = "unkown"; - int errorCode = ERROR_CODE_NOERROR; - try { - if (!lockPackageName(packageName)) { - throw new Exception("Package " + packageName + " is operating."); - } - System.setProperty("javax.net.ssl.trustStore", "*.keystore"); - System.setProperty("java.protocol.handler.pkgs", "com.sun.net.ssl.internal.www.protocol"); - System.setProperty("javax.net.ssl.trustStore", getConfig("jksFile")); - System.setProperty("javax.net.ssl.trustStorePassword", getConfig("trustStorePassword")); - - HttpTransportProperties.Authenticator authenticator = - new HttpTransportProperties.Authenticator(); - List<String> auth = new ArrayList<String>(); - auth.add(Authenticator.BASIC); - authenticator.setAuthSchemes(auth); - authenticator.setUsername(getConfig("httpUsername")); - authenticator.setPassword(getConfig("httpPassword")); - authenticator.setPreemptiveAuthentication(true); - - map.putAll(bpsUndeployPackage(packageName, authenticator)); - - return map; - } catch (AxisFault e) { - errorMessage = e.getLocalizedMessage(); - errorCode = ERROR_CODE_RUNTIME_EXCEPTION_AXIS; - log.error(e.getMessage(), e); - e.printStackTrace(); - } catch (Throwable e) { - errorMessage = e.getLocalizedMessage(); - if (e instanceof BpsServiceException) { - errorCode = ((BpsServiceException) e).getErrorCode(); - } else { - errorCode = ERROR_CODE_RUNTIME_EXCEPTION; - } - log.error(e.getMessage(), e); - e.printStackTrace(); - } finally { - if (packageName != null) { - unlockPackageName(packageName); - } - } - map.put("errorCode", errorCode); - map.put("status", STATUS_FAIL); - map.put("message", errorMessage); - return map; - } - - @SuppressWarnings({"rawtypes", "unused"}) - private Map<String, Object> bpsUndeployPackage(String packageName, - HttpTransportProperties.Authenticator authenticator) - throws JsonParseException, JsonMappingException, IOException, AxisFault, Exception { - Map<String, Object> map = new HashMap<String, Object>(); - Map deployedPackageInfoMap = getDeployedPackageInfo(authenticator, packageName, ""); - if (deployedPackageInfoMap.get("packageName") == null) { - throw new BpsServiceException(ERROR_CODE_PACKAGE_NOTEXISTS,"Package " + deployedPackageInfoMap.get("packageName") - + " does not exist, please deploy it first."); - } - OMElement element = undeployPackage(authenticator, packageName); - deployedPackageInfoMap = getDeployedPackageInfo(authenticator, packageName, ""); - if (deployedPackageInfoMap.get("packageName") != null) { - throw new BpsServiceException(ERROR_CODE_PACKAGE_UNDEPLOY_FAILED, - "Package " + deployedPackageInfoMap.get("packageName") + " undeploy failed."); - } - map.put("status", STATUS_SUCCESS); - map.put("message", "success"); - - return map; - } - - private OMElement undeployPackage(HttpTransportProperties.Authenticator authenticator, - String packageName) throws AxisFault { - String url = "https://" + getConfig("host") + ":" + getConfig("port") - + "/services/BPELPackageManagementService?wsdl"; - RPCServiceClient serviceClient = new RPCServiceClient(); - EndpointReference targetEPR = new EndpointReference(url); - Options options = serviceClient.getOptions(); - options.setTo(targetEPR); - options.setAction("sch:undeployBPELPackage"); - options.setProperty(HTTPConstants.SO_TIMEOUT, new Integer(300000)); - options.setProperty(HTTPConstants.AUTHENTICATE, authenticator); - serviceClient.setOptions(options); - OMFactory fac = OMAbstractFactory.getOMFactory(); - OMNamespace omNs = fac.createOMNamespace("http://wso2.org/bps/management/schema", "sch"); - OMElement method = fac.createOMElement("undeployBPELPackage", omNs); - OMElement content = fac.createOMElement("package", omNs); - content.addChild(fac.createOMText(content, packageName)); - method.addChild(content); - method.build(); - OMElement res = serviceClient.sendReceive(method); - return res; - } - - @SuppressWarnings({"rawtypes", "unchecked"}) - private Map getFullDeployedPackageInfo(HttpTransportProperties.Authenticator authenticator, - String packageName, String page) throws Exception { - String result; - String jsonTemplate = - "{'listDeployedPackagesPaginated':{'page':'${page}','packageSearchString':'${searchString}'}}"; - Map jsonParamMap = new HashMap(); - jsonParamMap.put("page", page); - jsonParamMap.put("searchString", packageName); - Object params = getParams(jsonTemplate, jsonParamMap); - result = BpsProcess.invokeWsdl("https://" + getConfig("host") + ":" + getConfig("port") - + "/services/BPELPackageManagementService?wsdl", params, authenticator); - Map<String, Object> processMap = JsonUtil.json2Bean(result, Map.class); - return processMap; - } - - @SuppressWarnings({"rawtypes", "unchecked"}) - private Map getDeployedPackageInfo(HttpTransportProperties.Authenticator authenticator, - String packageName, String page) throws Exception { - Map resultMap = new HashMap(); - Map<String, Object> processMap = getFullDeployedPackageInfo(authenticator, packageName, page); - Object packages = ((Map) processMap.get("deployedPackagesPaginated")).get("package"); - Map deployedPackage = null; - if (packages instanceof List) { - for (Iterator iter = ((List) packages).iterator(); iter.hasNext();) { - Map packageMap = (Map) iter.next(); - String deployedPackageName = (String) packageMap.get("name"); - if (deployedPackageName.equals(packageName)) { - deployedPackage = packageMap; - break; - } - } - } else if (packages instanceof Map) { - String deployedPackageName = (String) ((Map) packages).get("name"); - if (deployedPackageName.equals(packageName)) { - deployedPackage = (Map) packages; - } - } - if (deployedPackage != null) { - String fullPackageName = null; - String pid = null; - Object versions = ((Map) deployedPackage.get("versions")).get("version"); - Map lastestVersion = null; - if (versions instanceof List) { - for (Iterator iter = ((List) versions).iterator(); iter.hasNext();) { - Map version = (Map) iter.next(); - if (version.get("isLatest").equals("true")) { - lastestVersion = version; - } - } - } else if (versions instanceof Map) { - lastestVersion = (Map) versions; - } - fullPackageName = (String) ((Map) ((Map) lastestVersion.get("processes")).get("process")) - .get("packageName"); - pid = (String) ((Map) ((Map) lastestVersion.get("processes")).get("process")).get("pid"); - resultMap.put("packageName", fullPackageName); - resultMap.put("pid", pid); - } - return resultMap; -} - - - @SuppressWarnings({"rawtypes", "unchecked"}) - public static Map<String, Object> getParams(String jsonTemplate, Map<String, Object> paramMap) - throws JsonParseException, JsonMappingException, IOException { - String json = jsonTemplate.replaceAll("'", "\""); - for (Iterator iter = paramMap.keySet().iterator(); iter.hasNext();) { - String key = (String) iter.next(); - String value = ""; - if (paramMap.get(key) != null) { - value = paramMap.get(key).toString().replaceAll("\"", "\\\\\""); - } - json = json.replaceAll("\\$\\{" + key + "\\}", value); - } - return JsonUtil.json2Bean(json, Map.class); - } - - @GET - @Path(value = "listPackages") - @Produces(value = MediaType.APPLICATION_JSON) - @ApiOperation(value = "list packages", response = Map.class) - @Timed - public Map<String, Object> listPackages(@QueryParam("page") String page, - @QueryParam("searchString") String searchString, @Context HttpServletRequest request) - throws IOException { - Map<String, Object> map = new LinkedHashMap<String, Object>(); - String errorMessage = "unkown"; - int errorCode = ERROR_CODE_NOERROR; - String packageName = null; - try { - System.setProperty("javax.net.ssl.trustStore", "*.keystore"); - System.setProperty("java.protocol.handler.pkgs", "com.sun.net.ssl.internal.www.protocol"); - System.setProperty("javax.net.ssl.trustStore", getConfig("jksFile")); - System.setProperty("javax.net.ssl.trustStorePassword", getConfig("trustStorePassword")); - - HttpTransportProperties.Authenticator authenticator = - new HttpTransportProperties.Authenticator(); - List<String> auth = new ArrayList<String>(); - auth.add(Authenticator.BASIC); - authenticator.setAuthSchemes(auth); - authenticator.setUsername(getConfig("httpUsername")); - authenticator.setPassword(getConfig("httpPassword")); - authenticator.setPreemptiveAuthentication(true); - - map.putAll(getFullDeployedPackageInfo(authenticator,searchString,page)); - - map.put("status", STATUS_SUCCESS); - map.put("message", "success"); - return map; - } catch (AxisFault e) { - errorMessage = e.getLocalizedMessage(); - errorCode = ERROR_CODE_RUNTIME_EXCEPTION_AXIS; - log.error(e.getMessage(), e); - e.printStackTrace(); - } catch (IOException e) { - errorMessage = e.getLocalizedMessage(); - errorCode = ERROR_CODE_RUNTIME_EXCEPTION_IO; - log.error(e.getMessage(), e); - e.printStackTrace(); - } catch (Throwable e) { - if (e instanceof BpsServiceException) { - errorCode = ((BpsServiceException) e).getErrorCode(); - } else { - errorCode = ERROR_CODE_RUNTIME_EXCEPTION; - } - errorMessage = e.getLocalizedMessage(); - log.error(e.getMessage(), e); - e.printStackTrace(); - } finally { - if (packageName != null) { - unlockPackageName(packageName); - } - } - map.put("errorCode", errorCode); - map.put("status", STATUS_FAIL); - map.put("message", errorMessage); - return map; - } - - @SuppressWarnings("rawtypes") - public static void main(String[] args) { - try { - - boolean remoteDebug = true; - boolean localDebug = false; - if (remoteDebug) { - Client client = ClientBuilder.newBuilder().register(MultiPartFeature.class).build(); - WebTarget target = client.target("http://localhost:8101/openoapi/wso2bpel/v1/package"); - FileDataBodyPart bodyPart = new FileDataBodyPart("file", - new File("F:\\wso2bps-3.5.1\\wso2bps-3.5.1\\repository\\samples\\bpel\\Alarm.zip")); - FormDataMultiPart formDataMultiPart = new FormDataMultiPart(); - formDataMultiPart.field("fileName", "Alarm.zip").bodyPart(bodyPart); - String result = target.request(MediaType.APPLICATION_JSON) - .post(Entity.entity(formDataMultiPart, formDataMultiPart.getMediaType()), String.class); - System.out.println(result); - } - // - // System.out.println("************************************************************************"); - // - // bodyPart = new FileDataBodyPart("file", new - // File("D:\\temp\\bpel-sample\\AssignDate\\AssignDate.zip")); - // formDataMultiPart = new FormDataMultiPart(); - // formDataMultiPart.field("fileName", - // "AssignDate.zip").bodyPart(bodyPart); - // result = target.request(MediaType.APPLICATION_JSON) - // .post(Entity.entity(formDataMultiPart, - // formDataMultiPart.getMediaType()), String.class); - // System.out.println(result); - // - if (localDebug) { - System.setProperty("javax.net.ssl.trustStore", "*.keystore"); - System.setProperty("java.protocol.handler.pkgs", "com.sun.net.ssl.internal.www.protocol"); - System.setProperty("javax.net.ssl.trustStore", - "D:\\software\\WSO2\\wso2bps-3.5.1\\repository\\resources\\security\\wso2carbon.jks"); - System.setProperty("javax.net.ssl.trustStorePassword", "wso2carbon"); - HttpTransportProperties.Authenticator authenticator = - new HttpTransportProperties.Authenticator(); - List<String> auth = new ArrayList<String>(); - auth.add(Authenticator.BASIC); - authenticator.setAuthSchemes(auth); - authenticator.setUsername("admin"); - authenticator.setPassword("admin"); - authenticator.setPreemptiveAuthentication(true); - // - // String packageName = "RESTProcess"; - // Map deployedPackageInfoMap = - // getDeployedPackageInfo(authenticator, packageName); - - BpsPackage packageTest = new BpsPackage(); - Map map; - // map = packageTest.bpsUndeployPackage("AssignDate", - // authenticator); - // System.out.println(JsonUtil.bean2Json(map)); - map = packageTest.bpsDeployPackage("AssignDate.zip", - "D:\\temp\\bpel-sample\\AssignDate\\AssignDate.zip", "AssignDate", authenticator); - System.out.println(JsonUtil.bean2Json(map)); - map = packageTest.bpsUndeployPackage("AssignDate", authenticator); - System.out.println(JsonUtil.bean2Json(map)); - } - - } catch (Exception e) { - e.printStackTrace(); - } - } -} |