thoerup/asyncsamples/WorkManagerSample.java

/* using the workmanager api (as in JSR237 etc.)  
 * 
 * in websphere the workmanager API is available very easy on glassfish .... not so simple
 * 
 * this code is inspired by how Spring implented their TaskExecutor for GFv3, google : org.springframework.jca.work.glassfish.GlassFishWorkManagerTaskExecutor
 * 
 *  GFv3 Compile-time dependencies: auto-depends.jar connectors-runtime.jar connectors-internal-api.jar work-management.jar
 *   
 *  
 * if your container (eg. tomcat) does not support this take a look at CommonJ
 */

package dk.thoerup.asyncsamples;

import java.io.IOException;
import java.util.logging.Level;
import java.util.logging.Logger;

import javax.resource.spi.work.Work;
import javax.resource.spi.work.WorkManager;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import com.sun.enterprise.connectors.ConnectorRuntime;
import com.sun.enterprise.connectors.work.CommonWorkManager;


/**
 * Servlet implementation class WorkManager
 */
public class WorkManagerSample extends HttpServlet {
        private static final long serialVersionUID = 1L;
        
        static final Logger logger = Logger.getLogger(WorkManagerSample.class.getName());
        
        WorkManager mgr;
        
        class MyWork implements Work {
                @Override
                public void release() {                 
                }

                @Override
                public void run() {
                        DummyWork.doWork();
                }
                
        }

        @Override
        public void init() throws ServletException {
                super.init();
                
                ConnectorRuntime rt = ConnectorRuntime.getRuntime();
                
                final String threadPoolName = "thread-pool-1";

                try {
                        mgr = new CommonWorkManager(threadPoolName, rt, null);

                } catch (Exception e) {
                        logger.log(Level.SEVERE, "error", e);
                }
        }
        
        protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {

                try {
                        mgr.scheduleWork(new MyWork());
                } catch (Exception e) {
                        logger.log(Level.SEVERE, "error", e);
                }

                response.getWriter().print("Finished");
        }

}
1	/* using the workmanager api (as in JSR237 etc.)
2	*
3	* in websphere the workmanager API is available very easy on glassfish .... not so simple
4	*
5	* this code is inspired by how Spring implented their TaskExecutor for GFv3, google : org.springframework.jca.work.glassfish.GlassFishWorkManagerTaskExecutor
6	*
7	* GFv3 Compile-time dependencies: auto-depends.jar connectors-runtime.jar connectors-internal-api.jar work-management.jar
8	*
9	*
10	* if your container (eg. tomcat) does not support this take a look at CommonJ
11	*/
12
13	package dk.thoerup.asyncsamples;
14
15	import java.io.IOException;
16	import java.util.logging.Level;
17	import java.util.logging.Logger;
18
19	import javax.resource.spi.work.Work;
20	import javax.resource.spi.work.WorkManager;
21	import javax.servlet.ServletException;
22	import javax.servlet.http.HttpServlet;
23	import javax.servlet.http.HttpServletRequest;
24	import javax.servlet.http.HttpServletResponse;
25
26	import com.sun.enterprise.connectors.ConnectorRuntime;
27	import com.sun.enterprise.connectors.work.CommonWorkManager;
28
29
30
31
32	/**
33	* Servlet implementation class WorkManager
34	*/
35	public class WorkManagerSample extends HttpServlet {
36	private static final long serialVersionUID = 1L;
37
38	static final Logger logger = Logger.getLogger(WorkManagerSample.class.getName());
39
40	WorkManager mgr;
41
42	class MyWork implements Work {
43	@Override
44	public void release() {
45	}
46
47	@Override
48	public void run() {
49	DummyWork.doWork();
50	}
51
52	}
53
54	@Override
55	public void init() throws ServletException {
56	super.init();
57
58	ConnectorRuntime rt = ConnectorRuntime.getRuntime();
59
60	final String threadPoolName = "thread-pool-1";
61
62	try {
63	mgr = new CommonWorkManager(threadPoolName, rt, null);
64
65	} catch (Exception e) {
66	logger.log(Level.SEVERE, "error", e);
67	}
68	}
69
70	protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
71
72	try {
73	mgr.scheduleWork(new MyWork());
74	} catch (Exception e) {
75	logger.log(Level.SEVERE, "error", e);
76	}
77
78	response.getWriter().print("Finished");
79	}
80
81	}