1 22 package org.jboss.test.jca.test; 23 24 import javax.resource.cci.Connection ; 25 26 32 public class RecyclingStickyStressTestCase extends AbstractRecyclingPoolingStressTest 33 { 34 public boolean isSticky() 35 { 36 return true; 37 } 38 39 public void testIt() throws Throwable 40 { 41 tm.setTransactionTimeout(0); 42 RecyclingPoolingRunnable[] runnables = new RecyclingPoolingRunnable[getThreadCount()]; 43 for (int i = 0; i < runnables.length; ++i) 44 { 45 runnables[i] = new RecyclingPoolingRunnable() 46 { 47 public void doRun1() throws Throwable 48 { 49 Connection c = cf.getConnection(); 50 c.close(); 51 } 52 }; 53 } 54 55 runConcurrentTest(runnables, null); 56 } 57 58 public RecyclingStickyStressTestCase(String name) 59 { 60 super(name); 61 } 62 } 63 | Popular Tags |