deployservlet.java

workflow first jbpm

package com.yuyanshan.servlet;

import java.io.IOException;
import java.io.PrintWriter;
import java.net.URL;
import java.util.zip.ZipInputStream;

import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.jbpm.JbpmConfiguration;
import org.jbpm.JbpmContext;
import org.jbpm.graph.def.ProcessDefinition;
//import org.springframework.context.ApplicationContext;
//import org.springframework.web.context.support.WebApplicationContextUtils;
public class DeployServlet extends HttpServlet {

	private static final long serialVersionUID = 1L;

	  protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
	    String archive = request.getParameter("archive");
	    log.debug("deploying archive "+archive);
	    JbpmConfiguration jbpmConfiguration = JbpmConfiguration
		.getInstance();
//	    ApplicationContext ctx=WebApplicationContextUtils.getRequiredWebApplicationContext(request.getSession().getServletContext());
//	    JbpmConfiguration jbpmConfiguration=(JbpmConfiguration) ctx.getBean("jbpmConfiguration");
	    PrintWriter writer = response.getWriter();
	    try {
	      URL archiveUrl = new URL(archive);
	      System.out.println("******************************"+archiveUrl.toString());
	      ZipInputStream zis = new ZipInputStream(archiveUrl.openStream());
	      JbpmContext jbpmContext = jbpmConfiguration.getCurrentJbpmContext();
	      if(jbpmContext==null)
	      {
	    	  jbpmContext=jbpmConfiguration.createJbpmContext();
	      }
	      ProcessDefinition processDefinition = ProcessDefinition.parseParZipInputStream(zis);
	      jbpmContext.deployProcessDefinition(processDefinition);
	      zis.close();
	      jbpmContext.close();
	      writer.write("Deployed archive "+archive+" successfully");
	      
	    } catch (Exception e) {
	      e.printStackTrace();
	      writer.write("Deploying archive "+archive+" failed");
	    }
	  }

	  private static Log log = LogFactory.getLog(DeployServlet.class);
}