activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rajdav...@apache.org
Subject svn commit: r391051 - /incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTransactionTestSupport.java
Date Mon, 03 Apr 2006 14:13:31 GMT
Author: rajdavies
Date: Mon Apr  3 07:13:29 2006
New Revision: 391051

URL: http://svn.apache.org/viewcvs?rev=391051&view=rev
Log:
extended so can be used by Transaction tests for Master Slave

Modified:
    incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTransactionTestSupport.java

Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTransactionTestSupport.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTransactionTestSupport.java?rev=391051&r1=391050&r2=391051&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTransactionTestSupport.java
(original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTransactionTestSupport.java
Mon Apr  3 07:13:29 2006
@@ -16,30 +16,25 @@
  */
 package org.apache.activemq;
 
-import org.apache.activemq.ActiveMQConnection;
-import org.apache.activemq.ActiveMQPrefetchPolicy;
-import org.apache.activemq.broker.BrokerFactory;
-import org.apache.activemq.broker.BrokerService;
-import org.apache.activemq.test.JmsResourceProvider;
-import org.apache.activemq.test.TestSupport;
-
+import java.net.URI;
+import java.net.URISyntaxException;
+import java.util.ArrayList;
+import java.util.List;
 import javax.jms.Connection;
 import javax.jms.ConnectionFactory;
 import javax.jms.Destination;
 import javax.jms.JMSException;
 import javax.jms.Message;
 import javax.jms.MessageConsumer;
+import javax.jms.MessageListener;
 import javax.jms.MessageProducer;
 import javax.jms.ObjectMessage;
 import javax.jms.Session;
 import javax.jms.TextMessage;
-import javax.jms.MessageListener;
-
-import java.io.Serializable;
-import java.net.URI;
-import java.net.URISyntaxException;
-import java.util.ArrayList;
-import java.util.List;
+import org.apache.activemq.broker.BrokerFactory;
+import org.apache.activemq.broker.BrokerService;
+import org.apache.activemq.test.JmsResourceProvider;
+import org.apache.activemq.test.TestSupport;
 
 /**
  * @version $Revision: 1.9 $
@@ -63,8 +58,10 @@
     private List unackMessages = new ArrayList(messageCount);
     private List ackMessages = new ArrayList(messageCount);
     private boolean resendPhase = false;
+    protected int batchCount = 10;
+    protected int batchSize = 20;
 
-    private BrokerService broker;
+    protected BrokerService broker;
 
     public JmsTransactionTestSupport() {
         super();
@@ -116,8 +113,7 @@
      * @throws Exception
      */
     public void testSendReceiveTransactedBatches() throws Exception {
-        int batchCount = 10;
-        int batchSize = 20;
+       
         TextMessage message = session.createTextMessage("Batch Message");
 
         for (int j = 0; j < batchCount; j++) {



Mime
View raw message