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

Fix test case 

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@365713 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Hiram R. Chirino 2006-01-03 18:55:54 +00:00
parent a4618caf0c
commit 7dbbe0c854
1 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
activemq-core/src/test/java/org/apache/activemq/perf/SimpleDurableTopicTest.java
View File

@ -20,6 +20,8 @@ import javax.jms.ConnectionFactory;
import javax.jms.DeliveryMode; import javax.jms.DeliveryMode;
import javax.jms.Destination; import javax.jms.Destination;
import javax.jms.JMSException; import javax.jms.JMSException;
import org.apache.activemq.ActiveMQConnectionFactory;
/** /**
* @version $Revision: 1.3 $ * @version $Revision: 1.3 $
*/ */
@ -33,4 +35,10 @@ public class SimpleDurableTopicTest extends SimpleTopicTest{
protected PerfConsumer createConsumer(ConnectionFactory fac,Destination dest,int number) throws JMSException{ protected PerfConsumer createConsumer(ConnectionFactory fac,Destination dest,int number) throws JMSException{
return new PerfConsumer(fac,dest,"subs:"+number); return new PerfConsumer(fac,dest,"subs:"+number);
} }
protected ActiveMQConnectionFactory createConnectionFactory() throws Exception {
ActiveMQConnectionFactory cf = super.createConnectionFactory();
cf.setClientID(getName());
return cf;
}
} }