[jboss-svn-commits] JBL Code SVN: r31882 - labs/jbosstm/workspace/whitingjr/trunk/performance/src/test/java/org/jboss/jbossts/performance/configuration.

[jboss-svn-commits at lists.jboss.org]

Author: whitingjr
Date: 2010-03-01 10:36:42 -0500 (Mon, 01 Mar 2010)
New Revision: 31882

Modified:
   labs/jbosstm/workspace/whitingjr/trunk/performance/src/test/java/org/jboss/jbossts/performance/configuration/MultithreadedTestConfiguration.java
Log:
Added configuration of ConnectionHandler.


Modified: labs/jbosstm/workspace/whitingjr/trunk/performance/src/test/java/org/jboss/jbossts/performance/configuration/MultithreadedTestConfiguration.java
===================================================================
--- labs/jbosstm/workspace/whitingjr/trunk/performance/src/test/java/org/jboss/jbossts/performance/configuration/MultithreadedTestConfiguration.java	2010-03-01 15:36:15 UTC (rev 31881)
+++ labs/jbosstm/workspace/whitingjr/trunk/performance/src/test/java/org/jboss/jbossts/performance/configuration/MultithreadedTestConfiguration.java	2010-03-01 15:36:42 UTC (rev 31882)
@@ -3,6 +3,8 @@
 import java.util.List;
 import java.util.concurrent.CyclicBarrier;
 
+import org.jboss.jbossts.performance.task.pooling.ConnectionHandler;
+
 /**
  * This object holds the configuration for Task objects.
  * 
@@ -15,13 +17,16 @@
    private final CyclicBarrier completionBarrier;
    private final Long threadIdentity;
    private final List<Long> results;
+   private final Class<ConnectionHandler> connectionHandlerClass;
    public MultithreadedTestConfiguration(final Integer stable,
-         final CyclicBarrier barrier, final Long identity, final List<Long> threadResults)
+         final CyclicBarrier barrier, final Long identity, final List<Long> threadResults,
+         final Class<ConnectionHandler> connectionHandler)
    {
       this.iterationCount = stable;
       this.completionBarrier = barrier;
       this.threadIdentity = identity;
       this.results = threadResults;
+      this.connectionHandlerClass =  connectionHandler;
    }
 
    public Integer getIterationCount()
@@ -43,4 +48,9 @@
    {
       return results;
    }
+
+   public Class<ConnectionHandler> getConnectionHandlerClass()
+   {
+      return connectionHandlerClass;
+   }
 }