From 4e6cbcdc5fc551f8ead0548ab1a7e773879503a8 Mon Sep 17 00:00:00 2001
From: Timothy Bish <tabish121@gmail.com>
Date: Tue, 15 Mar 2016 11:40:17 -0400
Subject: [PATCH] NO-JIRA Use a real transport connector for the test to
 prevent failures in CI.

---
 .../PooledConnectionTempDestCleanupTest.java  | 20 ++++++++++++++++++-
 1 file changed, 19 insertions(+), 1 deletion(-)

diff --git a/activemq-jms-pool/src/test/java/org/apache/activemq/jms/pool/PooledConnectionTempDestCleanupTest.java b/activemq-jms-pool/src/test/java/org/apache/activemq/jms/pool/PooledConnectionTempDestCleanupTest.java
index 17b23871e6..5def9b7a76 100644
--- a/activemq-jms-pool/src/test/java/org/apache/activemq/jms/pool/PooledConnectionTempDestCleanupTest.java
+++ b/activemq-jms-pool/src/test/java/org/apache/activemq/jms/pool/PooledConnectionTempDestCleanupTest.java
@@ -19,6 +19,8 @@ package org.apache.activemq.jms.pool;
 
 import static org.junit.Assert.assertTrue;
 
+import java.net.URI;
+
 import javax.jms.Connection;
 import javax.jms.Destination;
 import javax.jms.JMSException;
@@ -27,10 +29,13 @@ import javax.jms.TemporaryQueue;
 
 import org.apache.activemq.ActiveMQConnectionFactory;
 import org.apache.activemq.broker.BrokerService;
+import org.apache.activemq.broker.TransportConnector;
 import org.apache.activemq.broker.region.RegionBroker;
 import org.junit.After;
 import org.junit.Before;
+import org.junit.Rule;
 import org.junit.Test;
+import org.junit.rules.TestName;
 
 /**
  * Test of lingering temporary destinations on pooled connections when the
@@ -42,6 +47,9 @@ import org.junit.Test;
  */
 public class PooledConnectionTempDestCleanupTest extends JmsPoolTestSupport {
 
+    @Rule
+    public TestName testName = new TestName();
+
     protected ActiveMQConnectionFactory directConnFact;
     protected Connection directConn1;
     protected Connection directConn2;
@@ -68,7 +76,7 @@ public class PooledConnectionTempDestCleanupTest extends JmsPoolTestSupport {
         brokerService.waitUntilStarted();
 
         // Create the ActiveMQConnectionFactory and the PooledConnectionFactory.
-        directConnFact = new ActiveMQConnectionFactory(brokerService.getVmConnectorURI());
+        directConnFact = new ActiveMQConnectionFactory(getBrokerConnectionURI());
         pooledConnFact = new PooledConnectionFactory();
         pooledConnFact.setConnectionFactory(directConnFact);
 
@@ -113,6 +121,16 @@ public class PooledConnectionTempDestCleanupTest extends JmsPoolTestSupport {
         brokerService.setPersistent(false);
         brokerService.setAdvisorySupport(false);
         brokerService.setSchedulerSupport(false);
+
+        TransportConnector connector = new TransportConnector();
+        connector.setUri(new URI("tcp://localhost:0"));
+        connector.setName(testName.getMethodName());
+
+        brokerService.addConnector(connector);
+    }
+
+    protected String getBrokerConnectionURI() throws Exception {
+        return brokerService.getTransportConnectorByName(testName.getMethodName()).getPublishableConnectString();
     }
 
     /**