svn commit: r500309 - /incubator/servicemix/trunk/distributions/apache-servicemix/src/main/release/examples/loan-broker/src/client/JMSClient.java

[gnodet]

Author: gnodet
Date: Fri Jan 26 11:09:49 2007
New Revision: 500309

URL: http://svn.apache.org/viewvc?view=rev&rev=500309
Log:
Fix jms client for loan-broker example

Modified:
    
incubator/servicemix/trunk/distributions/apache-servicemix/src/main/release/examples/loan-broker/src/client/JMSClient.java

Modified: 
incubator/servicemix/trunk/distributions/apache-servicemix/src/main/release/examples/loan-broker/src/client/JMSClient.java
URL: 
http://svn.apache.org/viewvc/incubator/servicemix/trunk/distributions/apache-servicemix/src/main/release/examples/loan-broker/src/client/JMSClient.java?view=diff&rev=500309&r1=500308&r2=500309
==============================================================================
--- 
incubator/servicemix/trunk/distributions/apache-servicemix/src/main/release/examples/loan-broker/src/client/JMSClient.java
 (original)
+++ 
incubator/servicemix/trunk/distributions/apache-servicemix/src/main/release/examples/loan-broker/src/client/JMSClient.java
 Fri Jan 26 11:09:49 2007
@@ -18,21 +18,19 @@
 
 import org.apache.activemq.ActiveMQConnectionFactory;
 import org.apache.activemq.command.ActiveMQQueue;
-import org.jencks.GeronimoPlatformTransactionManager;
-import org.jencks.factory.WorkManagerFactoryBean;
 import org.logicblaze.lingo.jms.Requestor;
 import org.logicblaze.lingo.jms.JmsProducerConfig;
 import org.logicblaze.lingo.jms.impl.MultiplexingRequestor;
-
+import edu.emory.mathcs.backport.java.util.concurrent.ExecutorService;
+import edu.emory.mathcs.backport.java.util.concurrent.Executors;
 import javax.jms.ConnectionFactory;
 import javax.jms.Destination;
 import javax.jms.Message;
-import javax.resource.spi.work.Work;
 
 /**
  * @version $Revision$
  */
-public class JMSClient implements Work {
+public class JMSClient implements Runnable {
     
     private static ConnectionFactory factory;
     private static CountDownLatch latch;
@@ -59,27 +57,17 @@
             if (args.length > 1) {
                 th = Integer.parseInt(args[1]);
             }
-            GeronimoWorkManager wm = createWorkManager(th);
             latch = new CountDownLatch(nb);
+            ExecutorService threadPool = Executors.newFixedThreadPool(th);
             for (int i = 0; i < nb; i++) {
-                wm.scheduleWork(new JMSClient());
+                threadPool.submit(new JMSClient());
             }
             latch.await();
-            wm.doStop();
         }
         System.out.println("Closing.");
         requestor.close();
     }
     
-    protected static GeronimoWorkManager createWorkManager(int poolSize) 
throws Exception {
-        WorkManagerFactoryBean wmfb = new WorkManagerFactoryBean();
-        wmfb.setManager(new GeronimoPlatformTransactionManager());
-        wmfb.setThreadPoolSize(poolSize);
-        wmfb.afterPropertiesSet();
-        GeronimoWorkManager wm = wmfb.getWorkManager();
-        return wm;
-    }
-
     public void run() {
         try {
             System.out.println("Sending request.");
@@ -103,6 +91,4 @@
         }
     }
 
-    public void release() {
-    }
 }