Apache/activemq
1
0
Fork 0
mirror of https://github.com/apache/activemq.git synced 2025-02-17 07:24:51 +00:00
Code Issues Packages Projects Releases Wiki Activity

extended so can be used by Transaction tests for Master Slave

Browse Source 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@391051 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Robert Davies 2006-04-03 14:13:29 +00:00
parent 0a7ade231a
commit 0e6a7e4897
1 changed files with 13 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
activemq-core/src/test/java/org/apache/activemq/JmsTransactionTestSupport.java
View File

@ -16,30 +16,25 @@
*/ */
package org.apache.activemq; package org.apache.activemq;
import org.apache.activemq.ActiveMQConnection; import java.net.URI;
import org.apache.activemq.ActiveMQPrefetchPolicy; import java.net.URISyntaxException;
import org.apache.activemq.broker.BrokerFactory; import java.util.ArrayList;
import org.apache.activemq.broker.BrokerService; import java.util.List;
import org.apache.activemq.test.JmsResourceProvider;
import org.apache.activemq.test.TestSupport;
import javax.jms.Connection; import javax.jms.Connection;
import javax.jms.ConnectionFactory; import javax.jms.ConnectionFactory;
import javax.jms.Destination; import javax.jms.Destination;
import javax.jms.JMSException; import javax.jms.JMSException;
import javax.jms.Message; import javax.jms.Message;
import javax.jms.MessageConsumer; import javax.jms.MessageConsumer;
import javax.jms.MessageListener;
import javax.jms.MessageProducer; import javax.jms.MessageProducer;
import javax.jms.ObjectMessage; import javax.jms.ObjectMessage;
import javax.jms.Session; import javax.jms.Session;
import javax.jms.TextMessage; import javax.jms.TextMessage;
import javax.jms.MessageListener; import org.apache.activemq.broker.BrokerFactory;
import org.apache.activemq.broker.BrokerService;
import java.io.Serializable; import org.apache.activemq.test.JmsResourceProvider;
import java.net.URI; import org.apache.activemq.test.TestSupport;
import java.net.URISyntaxException;
import java.util.ArrayList;
import java.util.List;
/** /**
* @version $Revision: 1.9 $ * @version $Revision: 1.9 $
@ -63,8 +58,10 @@ abstract public class JmsTransactionTestSupport extends TestSupport implements M
private List unackMessages = new ArrayList(messageCount); private List unackMessages = new ArrayList(messageCount);
private List ackMessages = new ArrayList(messageCount); private List ackMessages = new ArrayList(messageCount);
private boolean resendPhase = false; private boolean resendPhase = false;
protected int batchCount = 10;
protected int batchSize = 20;
private BrokerService broker; protected BrokerService broker;
public JmsTransactionTestSupport() { public JmsTransactionTestSupport() {
super(); super();
@ -116,8 +113,7 @@ abstract public class JmsTransactionTestSupport extends TestSupport implements M
* @throws Exception * @throws Exception
*/ */
public void testSendReceiveTransactedBatches() throws Exception { public void testSendReceiveTransactedBatches() throws Exception {
int batchCount = 10;
int batchSize = 20;
TextMessage message = session.createTextMessage("Batch Message"); TextMessage message = session.createTextMessage("Batch Message");
for (int j = 0; j < batchCount; j++) { for (int j = 0; j < batchCount; j++) {