Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Updated to use new activemq package names 

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@359637 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Hiram R. Chirino 2005-12-28 20:49:18 +00:00
parent 9141677e4a
commit c901884014
7 changed files with 34 additions and 40 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
jmeter/src/java/org/activemq/sampler/Consumer.java
View File

@ -16,7 +16,7 @@
*/
package org.activemq.sampler;
import org.activemq.util.IdGenerator;
import org.apache.activemq.util.IdGenerator;
import org.activemq.util.connection.ServerConnectionFactory;
import org.apache.jmeter.samplers.Entry;
import org.apache.jmeter.samplers.SampleResult;

4
jmeter/src/java/org/activemq/sampler/ConsumerSysTest.java
View File

@ -22,8 +22,8 @@ import org.apache.jmeter.util.JMeterUtils;
import org.apache.jmeter.samplers.SampleResult;
import org.apache.jmeter.samplers.Entry;
import org.activemq.util.connection.ServerConnectionFactory;
import org.activemq.util.IdGenerator;
import org.activemq.command.ActiveMQMessage;
import org.apache.activemq.util.IdGenerator;
import org.apache.activemq.command.ActiveMQMessage;
import javax.jms.*;
import java.util.*;

2
jmeter/src/java/org/activemq/sampler/Producer.java
View File

@ -24,7 +24,7 @@ import org.apache.jmeter.util.JMeterUtils;
import org.apache.jorphan.logging.LoggingManager;
import org.apache.log.Logger;
import org.activemq.util.connection.ServerConnectionFactory;
import org.activemq.util.IdGenerator;
import org.apache.activemq.util.IdGenerator;
import javax.jms.Connection;
import javax.jms.Session;

2
jmeter/src/java/org/activemq/sampler/ProducerSysTest.java
View File

@ -25,7 +25,7 @@ import org.apache.log.Logger;
import org.apache.jorphan.logging.LoggingManager;
import org.activemq.util.connection.ServerConnectionFactory;
import org.activemq.util.IdGenerator;
import org.apache.activemq.util.IdGenerator;
import javax.jms.*;
import java.io.File;

40
jmeter/src/java/org/activemq/util/connection/ServerConnectionFactory.java
View File

@ -16,34 +16,32 @@
*/
package org.activemq.util.connection;
import org.activemq.ActiveMQConnectionFactory;
import org.activemq.ActiveMQConnection;
import org.mr.api.jms.MantaTopicConnectionFactory;
import org.mr.api.jms.MantaQueueConnectionFactory;
import org.apache.jmeter.util.JMeterUtils;
import java.lang.reflect.Constructor;
import java.lang.reflect.InvocationTargetException;
import java.util.Properties;
import javax.jms.Connection;
import javax.jms.Session;
import javax.jms.JMSException;
import javax.jms.Topic;
import javax.jms.Queue;
import javax.jms.ConnectionFactory;
import javax.jms.TopicConnectionFactory;
import javax.jms.QueueConnectionFactory;
import javax.jms.TopicSession;
import javax.jms.QueueSession;
import javax.jms.Destination;
import javax.jms.TopicConnection;
import javax.jms.JMSException;
import javax.jms.Queue;
import javax.jms.QueueConnection;
import javax.jms.QueueConnectionFactory;
import javax.jms.QueueSession;
import javax.jms.Session;
import javax.jms.Topic;
import javax.jms.TopicConnection;
import javax.jms.TopicConnectionFactory;
import javax.jms.TopicSession;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;
import java.lang.reflect.Constructor;
import java.lang.reflect.InvocationTargetException;
import java.util.Properties;
import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.jmeter.util.JMeterUtils;
import org.mr.api.jms.MantaQueueConnectionFactory;
import org.mr.api.jms.MantaTopicConnectionFactory;
/**
* Provides static methods for creating Session and Destination objects.
@ -203,10 +201,6 @@ public class ServerConnectionFactory {
ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory(url);
factory.setUseAsyncSend(true);
if (embeddedBroker) {
factory.setUseEmbeddedBroker(true);
}
ActiveMQConnection c = (ActiveMQConnection) factory.createConnection();
c.getPrefetchPolicy().setQueuePrefetch(1000);

10
jmeter/src/test/java/org/activemq/usecases/NoDestinationErrorTest.java
View File

@ -8,11 +8,11 @@ import java.net.URI;
import junit.framework.TestCase;
import org.activemq.ActiveMQConnectionFactory;
import org.activemq.ActiveMQConnection;
import org.activemq.broker.BrokerService;
import org.activemq.broker.BrokerFactory;
import org.activemq.broker.TransportConnector;
import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.broker.BrokerService;
import org.apache.activemq.broker.BrokerFactory;
import org.apache.activemq.broker.TransportConnector;
/**
* This Unit Test is created to test the memory leakage when a new producer is created and closed for each message that was sent.

14
jmeter/src/test/java/org/activemq/usecases/SystemTestSupport.java
View File

@ -6,13 +6,13 @@ import javax.jms.*;
import java.util.*;
import java.net.URI;
import org.activemq.ActiveMQConnection;
import org.activemq.ActiveMQConnectionFactory;
import org.activemq.command.ActiveMQMessage;
import org.activemq.command.ActiveMQDestination;
import org.activemq.broker.BrokerService;
import org.activemq.broker.BrokerFactory;
import org.activemq.broker.TransportConnector;
import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.command.ActiveMQMessage;
import org.apache.activemq.command.ActiveMQDestination;
import org.apache.activemq.broker.BrokerService;
import org.apache.activemq.broker.BrokerFactory;
import org.apache.activemq.broker.TransportConnector;
import org.apache.jorphan.logging.LoggingManager;
import org.apache.log.Logger;