diff --git a/activemq-core/src/test/java/org/apache/activemq/perf/SimpleDurableTopicTest.java b/activemq-core/src/test/java/org/apache/activemq/perf/SimpleDurableTopicTest.java
index 9e65f30580..e68c19a02d 100644
--- a/activemq-core/src/test/java/org/apache/activemq/perf/SimpleDurableTopicTest.java
+++ b/activemq-core/src/test/java/org/apache/activemq/perf/SimpleDurableTopicTest.java
@@ -20,6 +20,8 @@ import javax.jms.ConnectionFactory;
 import javax.jms.DeliveryMode;
 import javax.jms.Destination;
 import javax.jms.JMSException;
+
+import org.apache.activemq.ActiveMQConnectionFactory;
 /**
  * @version $Revision: 1.3 $
  */
@@ -33,4 +35,10 @@ public class SimpleDurableTopicTest extends SimpleTopicTest{
     protected PerfConsumer createConsumer(ConnectionFactory fac,Destination dest,int number) throws JMSException{
         return new PerfConsumer(fac,dest,"subs:"+number);
     }
+    
+    protected ActiveMQConnectionFactory createConnectionFactory() throws Exception {
+        ActiveMQConnectionFactory cf = super.createConnectionFactory();
+        cf.setClientID(getName());
+        return cf;
+    }
 }
\ No newline at end of file