[#noissue] Fix port conflicts in integration test

plugins-it/activemq-it/src/test/java/com/navercorp/pinpoint/plugin/activemq/client/ActiveMQClientMultipleBrokersIT.java

@@ -17,6 +17,7 @@
 package com.navercorp.pinpoint.plugin.activemq.client;
 
 import com.navercorp.pinpoint.plugin.activemq.client.util.ActiveMQClientITHelper;
+import com.navercorp.pinpoint.plugin.activemq.client.util.PortUtils;
 import com.navercorp.pinpoint.plugin.activemq.client.util.TestBroker;
 import com.navercorp.pinpoint.pluginit.utils.AgentPath;
 import com.navercorp.pinpoint.test.plugin.Dependency;
@@ -46,14 +47,12 @@ public class ActiveMQClientMultipleBrokersIT extends ActiveMQClientITBase {
     private static final String PRODUCER_BROKER = "Producer_Broker";
     private static final String CONSUMER_BROKER = "Consumer_Broker";
 
-    private static String PRODUCER_BROKER_URL;
-    private static String CONSUMER_BROKER_URL;
+    private static final int PORT = SocketUtils.findAvailableTcpPort(PortUtils.DEFAULT_PORT);
+    private static final String PRODUCER_BROKER_URL = PortUtils.findAvailableUrl(PORT);
+    private static final String CONSUMER_BROKER_URL = PortUtils.findAvailableUrl(PORT + 1);
 
     @BeforeClass
     public static void setUpBeforeClass() throws Exception {
-        int producerPort = SocketUtils.findAvailableTcpPort(61616);
-        PRODUCER_BROKER_URL = "tcp://127.0.0.1:" + producerPort;
-        CONSUMER_BROKER_URL = "tcp://127.0.0.1:" + (producerPort + 1);
         ActiveMQClientITHelper.startBrokers(Arrays.asList(
                 // Consumer broker
                 new TestBroker.TestBrokerBuilder(CONSUMER_BROKER)

plugins-it/activemq-it/src/test/java/com/navercorp/pinpoint/plugin/activemq/client/ActiveMQClientMultipleBrokers_5_15_x_IT.java

@@ -17,6 +17,7 @@
 package com.navercorp.pinpoint.plugin.activemq.client;
 
 import com.navercorp.pinpoint.plugin.activemq.client.util.ActiveMQClientITHelper;
+import com.navercorp.pinpoint.plugin.activemq.client.util.PortUtils;
 import com.navercorp.pinpoint.plugin.activemq.client.util.TestBroker;
 import com.navercorp.pinpoint.pluginit.utils.AgentPath;
 import com.navercorp.pinpoint.test.plugin.Dependency;
@@ -25,6 +26,7 @@
 import com.navercorp.pinpoint.test.plugin.PinpointAgent;
 import com.navercorp.pinpoint.test.plugin.PinpointConfig;
 import com.navercorp.pinpoint.test.plugin.PinpointPluginTestSuite;
+import com.navercorp.pinpoint.testcase.util.SocketUtils;
 import org.junit.AfterClass;
 import org.junit.BeforeClass;
 import org.junit.runner.RunWith;
@@ -47,8 +49,9 @@ public class ActiveMQClientMultipleBrokers_5_15_x_IT extends ActiveMQClientITBas
     private static final String PRODUCER_BROKER = "Producer_Broker";
     private static final String CONSUMER_BROKER = "Consumer_Broker";
 
-    private static final String PRODUCER_BROKER_URL = "tcp://127.0.0.1:61616";
-    private static final String CONSUMER_BROKER_URL = "tcp://127.0.0.1:61617";
+    private static int PORT = SocketUtils.findAvailableTcpPort(PortUtils.DEFAULT_PORT);
+    private static final String PRODUCER_BROKER_URL = PortUtils.findAvailableUrl(PORT);
+    private static final String CONSUMER_BROKER_URL = PortUtils.findAvailableUrl(PORT + 1);
 
     @BeforeClass
     public static void setUpBeforeClass() throws Exception {

plugins-it/activemq-it/src/test/java/com/navercorp/pinpoint/plugin/activemq/client/ActiveMQClientSingleBrokerIT.java

@@ -17,6 +17,7 @@
 package com.navercorp.pinpoint.plugin.activemq.client;
 
 import com.navercorp.pinpoint.plugin.activemq.client.util.ActiveMQClientITHelper;
+import com.navercorp.pinpoint.plugin.activemq.client.util.PortUtils;
 import com.navercorp.pinpoint.plugin.activemq.client.util.TestBroker;
 import com.navercorp.pinpoint.pluginit.utils.AgentPath;
 import com.navercorp.pinpoint.test.plugin.Dependency;
@@ -29,6 +30,7 @@
 import org.junit.runner.RunWith;
 
 import java.util.Arrays;
+import java.util.Collections;
 
 /**
  * @author HyunGil Jeong
@@ -43,11 +45,12 @@
 public class ActiveMQClientSingleBrokerIT extends ActiveMQClientITBase {
 
     private static final String BROKER_NAME = "Test_Broker";
-    private static final String BROKER_URL = TestBroker.DEFAULT_BROKER_URL;
+
+    private static final String BROKER_URL = PortUtils.findAvailableUrl(PortUtils.DEFAULT_PORT);
 
     @BeforeClass
     public static void setUpBeforeClass() throws Exception {
-        ActiveMQClientITHelper.startBrokers(Arrays.asList(
+        ActiveMQClientITHelper.startBrokers(Collections.singletonList(
                 new TestBroker.TestBrokerBuilder(BROKER_NAME)
                         .addConnector(BROKER_URL)
                         .build()

plugins-it/activemq-it/src/test/java/com/navercorp/pinpoint/plugin/activemq/client/ActiveMQClientSingleBroker_5_15_x_IT.java

@@ -17,6 +17,7 @@
 package com.navercorp.pinpoint.plugin.activemq.client;
 
 import com.navercorp.pinpoint.plugin.activemq.client.util.ActiveMQClientITHelper;
+import com.navercorp.pinpoint.plugin.activemq.client.util.PortUtils;
 import com.navercorp.pinpoint.plugin.activemq.client.util.TestBroker;
 import com.navercorp.pinpoint.pluginit.utils.AgentPath;
 import com.navercorp.pinpoint.test.plugin.Dependency;
@@ -29,7 +30,7 @@
 import org.junit.BeforeClass;
 import org.junit.runner.RunWith;
 
-import java.util.Arrays;
+import java.util.Collections;
 
 /**
  * @author HyunGil Jeong
@@ -45,11 +46,11 @@
 public class ActiveMQClientSingleBroker_5_15_x_IT extends ActiveMQClientITBase {
 
     private static final String BROKER_NAME = "Test_Broker";
-    private static final String BROKER_URL = TestBroker.DEFAULT_BROKER_URL;
+    private static final String BROKER_URL = PortUtils.findAvailableUrl(PortUtils.DEFAULT_PORT);
 
     @BeforeClass
     public static void setUpBeforeClass() throws Exception {
-        ActiveMQClientITHelper.startBrokers(Arrays.asList(
+        ActiveMQClientITHelper.startBrokers(Collections.singletonList(
                 new TestBroker.TestBrokerBuilder(BROKER_NAME)
                         .addConnector(BROKER_URL)
                         .build()

plugins-it/activemq-it/src/test/java/com/navercorp/pinpoint/plugin/activemq/client/util/PortUtils.java

@@ -0,0 +1,14 @@
+package com.navercorp.pinpoint.plugin.activemq.client.util;
+
+import com.navercorp.pinpoint.testcase.util.SocketUtils;
+
+public final class PortUtils {
+    public static final String DEFAULT_HOST = "tcp://127.0.0.1";
+    public static final int DEFAULT_PORT = 61616;
+
+    public static String findAvailableUrl(int minPort) {
+        int port = SocketUtils.findAvailableTcpPort(minPort);
+        return DEFAULT_HOST + ":" + port;
+    }
+
+}

plugins-it/activemq-it/src/test/java/com/navercorp/pinpoint/plugin/activemq/client/util/TestBroker.java

@@ -34,8 +34,6 @@
  */
 public class TestBroker {
 
-    public static final String DEFAULT_BROKER_URL = "tcp://127.0.0.1:61616";
-
     private final String brokerName;
     private final BrokerService brokerService;
     private final Map<String, ActiveMQConnectionFactory> connectionFactories;
@@ -51,7 +49,7 @@ String getBrokerName() {
         return this.brokerName;
     }
 
-    ActiveMQConnection getConnection(String connectUri) throws JMSException {
+    ActiveMQConnection getConnection(String connectUri) {
         if (!this.connections.containsKey(connectUri)) {
             throw new IllegalArgumentException("Connection for connectUri [" + connectUri + "] does not exist");
         }
@@ -104,7 +102,7 @@ public TestBrokerBuilder addNetworkConnector(String discoveryAddress) {
 
         public TestBroker build() throws Exception {
             if (this.connectors.isEmpty()) {
-                this.connectors.add(DEFAULT_BROKER_URL);
+                throw new IllegalStateException("bindAddress is empty");
             }
             BrokerService brokerService = new BrokerService();
             brokerService.setBrokerName(this.brokerName);

plugins-it/mongodb-it/src/test/java/com/navercorp/pinpoint/plugin/mongodb/MongoDBITBase.java

@@ -151,7 +151,7 @@ public void insertComlexBsonValueData30(PluginTestVerifier verifier, MongoCollec
         Method insertOneMethod = getMethod(mongoDatabaseImpl, "insertOne", Object.class);
         NormalizedBson parsedBson = parseBson(document);
 
-        verifier.verifyTrace(event(MONGO_EXECUTE_QUERY, insertOneMethod, null, MongoDBITConstants.MONGODB_ADDRESS, null
+        verifier.verifyTrace(event(MONGO_EXECUTE_QUERY, insertOneMethod, null, mongod.getAddress(), null
                 , new ExpectedAnnotation(MongoConstants.MONGO_COLLECTION_INFO.getName(), collectionInfo)
                 , new ExpectedAnnotation(MongoConstants.MONGO_COLLECTION_OPTION.getName(), collectionOption)
                 , new ExpectedAnnotation(MongoConstants.MONGO_JSON_DATA.getName(), new StringStringValue(parsedBson.getNormalizedBson(), parsedBson.getParameter()))));
@@ -209,7 +209,7 @@ public void insertComlexBsonValueData34(PluginTestVerifier verifier, MongoCollec
         Method insertOneMethod = getMethod(mongoDatabaseImpl, "insertOne", Object.class);
         NormalizedBson parsedBson = parseBson(document);
 
-        verifier.verifyTrace(event(MONGO_EXECUTE_QUERY, insertOneMethod, null, MongoDBITConstants.MONGODB_ADDRESS, null
+        verifier.verifyTrace(event(MONGO_EXECUTE_QUERY, insertOneMethod, null, mongod.getAddress(), null
                 , new ExpectedAnnotation(MongoConstants.MONGO_COLLECTION_INFO.getName(), collectionInfo)
                 , new ExpectedAnnotation(MongoConstants.MONGO_COLLECTION_OPTION.getName(), collectionOption)
                 , new ExpectedAnnotation(MongoConstants.MONGO_JSON_DATA.getName(), new StringStringValue(parsedBson.getNormalizedBson(), parsedBson.getParameter()))));
@@ -223,7 +223,7 @@ public void insertData(PluginTestVerifier verifier, MongoCollection<Document> co
         Method insertOneMethod = getMethod(mongoDatabaseImpl, "insertOne", Object.class);
         NormalizedBson parsedBson = parseBson(doc);
 
-        verifier.verifyTrace(event(MONGO_EXECUTE_QUERY, insertOneMethod, null, MongoDBITConstants.MONGODB_ADDRESS, null
+        verifier.verifyTrace(event(MONGO_EXECUTE_QUERY, insertOneMethod, null, mongod.getAddress(), null
                 , new ExpectedAnnotation(MongoConstants.MONGO_COLLECTION_INFO.getName(), collectionInfo)
                 , new ExpectedAnnotation(MongoConstants.MONGO_COLLECTION_OPTION.getName(), collectionOption)
                 , new ExpectedAnnotation(MongoConstants.MONGO_JSON_DATA.getName(), new StringStringValue(parsedBson.getNormalizedBson(), parsedBson.getParameter()))));
@@ -238,7 +238,7 @@ public void updateData(PluginTestVerifier verifier, MongoCollection<Document> co
         Method updateOne = getMethod(mongoDatabaseImpl, "updateOne", Bson.class, Bson.class);
         NormalizedBson parsedBson = parseBson(doc, doc2);
 
-        verifier.verifyTrace(event(MONGO_EXECUTE_QUERY, updateOne, null, MongoDBITConstants.MONGODB_ADDRESS, null
+        verifier.verifyTrace(event(MONGO_EXECUTE_QUERY, updateOne, null, mongod.getAddress(), null
                 , new ExpectedAnnotation(MongoConstants.MONGO_COLLECTION_INFO.getName(), "customers")
                 , new ExpectedAnnotation(MongoConstants.MONGO_COLLECTION_OPTION.getName(), "MAJORITY")
                 , new ExpectedAnnotation(MongoConstants.MONGO_JSON_DATA.getName(), new StringStringValue(parsedBson.getNormalizedBson(), parsedBson.getParameter()))));
@@ -251,7 +251,7 @@ public void readData(PluginTestVerifier verifier, MongoCollection<Document> coll
 
         Method find = getMethod(mongoDatabaseImpl, "find");
 
-        verifier.verifyTrace(event(MONGO_EXECUTE_QUERY, find, null, MongoDBITConstants.MONGODB_ADDRESS, null
+        verifier.verifyTrace(event(MONGO_EXECUTE_QUERY, find, null, mongod.getAddress(), null
                 , new ExpectedAnnotation(MongoConstants.MONGO_COLLECTION_INFO.getName(), "customers")
                 , new ExpectedAnnotation(MongoConstants.MONGO_COLLECTION_OPTION.getName(), "secondaryPreferred")));
 
@@ -279,7 +279,7 @@ public void deleteData(PluginTestVerifier verifier, MongoCollection<Document> co
         Method deleteMany = getMethod(mongoDatabaseImpl, "deleteMany", Bson.class);
         NormalizedBson parsedBson = parseBson(doc);
 
-        verifier.verifyTrace(event(MONGO_EXECUTE_QUERY, deleteMany, null, MongoDBITConstants.MONGODB_ADDRESS, null
+        verifier.verifyTrace(event(MONGO_EXECUTE_QUERY, deleteMany, null, mongod.getAddress(), null
                 , new ExpectedAnnotation(MongoConstants.MONGO_COLLECTION_INFO.getName(), "customers")
                 , new ExpectedAnnotation(MongoConstants.MONGO_COLLECTION_OPTION.getName(), "MAJORITY")
                 , new ExpectedAnnotation(MongoConstants.MONGO_JSON_DATA.getName(), new StringStringValue(parsedBson.getNormalizedBson(), parsedBson.getParameter()))));
@@ -294,7 +294,7 @@ public void filterData(PluginTestVerifier verifier, MongoCollection<Document> co
 
         MongoCursor<Document> cursor = collection.find(bson).iterator();
 
-        verifier.verifyTrace(event(MONGO_EXECUTE_QUERY, find, null, MongoDBITConstants.MONGODB_ADDRESS, null
+        verifier.verifyTrace(event(MONGO_EXECUTE_QUERY, find, null, mongod.getAddress(), null
                 , new ExpectedAnnotation(MongoConstants.MONGO_COLLECTION_INFO.getName(), "customers")
                 , new ExpectedAnnotation(MongoConstants.MONGO_COLLECTION_OPTION.getName(), "secondaryPreferred")
                 , new ExpectedAnnotation(MongoConstants.MONGO_JSON_DATA.getName(), new StringStringValue(parsedBson.getNormalizedBson(), parsedBson.getParameter()))));
@@ -309,7 +309,7 @@ public void filterData2(PluginTestVerifier verifier, MongoCollection<Document> c
 
         MongoCursor<Document> cursor = collection.find(bson).iterator();
 
-        verifier.verifyTrace(event(MONGO_EXECUTE_QUERY, find, null, MongoDBITConstants.MONGODB_ADDRESS, null
+        verifier.verifyTrace(event(MONGO_EXECUTE_QUERY, find, null, mongod.getAddress(), null
                 , new ExpectedAnnotation(MongoConstants.MONGO_COLLECTION_INFO.getName(), "customers")
                 , new ExpectedAnnotation(MongoConstants.MONGO_COLLECTION_OPTION.getName(), "secondaryPreferred")
                 , new ExpectedAnnotation(MongoConstants.MONGO_JSON_DATA.getName(), new StringStringValue(parsedBson.getNormalizedBson(), parsedBson.getParameter()))));

plugins-it/mongodb-it/src/test/java/com/navercorp/pinpoint/plugin/mongodb/MongoDBITConstants.java

@@ -20,9 +20,7 @@ public final class MongoDBITConstants {
 
     public static final String BIND_ADDRESS = "localhost";
 
-    public static final int PORT = 27018;
-
-    public static final String MONGODB_ADDRESS = BIND_ADDRESS + ":" + PORT;
+    public static final int DEFAULT_PORT = 27018;
 
     public static final String EMBED_MONGODB_VERSION = "de.flapdoodle.embed:de.flapdoodle.embed.mongo:3.4.6";
 

plugins-it/mongodb-it/src/test/java/com/navercorp/pinpoint/plugin/mongodb/MongoDBIT_3_0_x_IT.java

@@ -29,7 +29,6 @@
 
 import com.mongodb.client.MongoCollection;
 import org.bson.Document;
-import org.junit.AfterClass;
 import org.junit.BeforeClass;
 import org.junit.runner.RunWith;
 
@@ -65,7 +64,7 @@ void insertComplex(PluginTestVerifier verifier, MongoCollection<Document> collec
 
     @Override
     public void setClient() {
-        mongoClient = new com.mongodb.MongoClient(MongoDBITConstants.BIND_ADDRESS, MongoDBITConstants.PORT);
+        mongoClient = new com.mongodb.MongoClient(MongoDBITConstants.BIND_ADDRESS, mongod.getPort());
 
         database = mongoClient.getDatabase("myMongoDbFake").withReadPreference(ReadPreference.secondaryPreferred()).withWriteConcern(WriteConcern.MAJORITY);
     }

plugins-it/mongodb-it/src/test/java/com/navercorp/pinpoint/plugin/mongodb/MongoDBIT_3_2_x_IT.java

@@ -29,8 +29,6 @@
 
 import com.mongodb.client.MongoCollection;
 import org.bson.Document;
-import org.junit.AfterClass;
-import org.junit.BeforeClass;
 import org.junit.runner.RunWith;
 
 /**
@@ -60,7 +58,7 @@ void insertComplex(PluginTestVerifier verifier, MongoCollection<Document> collec
 
     @Override
     public void setClient() {
-        mongoClient = new com.mongodb.MongoClient(MongoDBITConstants.BIND_ADDRESS, MongoDBITConstants.PORT);
+        mongoClient = new com.mongodb.MongoClient(MongoDBITConstants.BIND_ADDRESS, mongod.getPort());
         database = mongoClient.getDatabase("myMongoDbFake").withReadPreference(ReadPreference.secondaryPreferred()).withWriteConcern(WriteConcern.MAJORITY);
     }
 

plugins-it/mongodb-it/src/test/java/com/navercorp/pinpoint/plugin/mongodb/MongoDBIT_3_4_x_IT.java

@@ -29,8 +29,6 @@
 
 import com.mongodb.client.MongoCollection;
 import org.bson.Document;
-import org.junit.AfterClass;
-import org.junit.BeforeClass;
 import org.junit.runner.RunWith;
 
 /**
@@ -60,7 +58,7 @@ void insertComplex(PluginTestVerifier verifier, MongoCollection<Document> collec
 
     @Override
     public void setClient() {
-        mongoClient = new com.mongodb.MongoClient(MongoDBITConstants.BIND_ADDRESS, MongoDBITConstants.PORT);
+        mongoClient = new com.mongodb.MongoClient(MongoDBITConstants.BIND_ADDRESS, mongod.getPort());
         database = mongoClient.getDatabase("myMongoDbFake").withReadPreference(ReadPreference.secondaryPreferred()).withWriteConcern(WriteConcern.MAJORITY);
     }
 

plugins-it/mongodb-it/src/test/java/com/navercorp/pinpoint/plugin/mongodb/MongoDBIT_3_7_x_IT.java

@@ -31,8 +31,6 @@
 
 import com.mongodb.client.MongoCollection;
 import org.bson.Document;
-import org.junit.AfterClass;
-import org.junit.BeforeClass;
 import org.junit.runner.RunWith;
 
 /**
@@ -62,7 +60,7 @@ void insertComplex(PluginTestVerifier verifier, MongoCollection<Document> collec
 
     @Override
     public void setClient() {
-        mongoClient = MongoClients.create("mongodb://" + MongoDBITConstants.MONGODB_ADDRESS);
+        mongoClient = MongoClients.create("mongodb://" + mongod.getAddress());
         database = mongoClient.getDatabase("myMongoDbFake").withReadPreference(ReadPreference.secondaryPreferred()).withWriteConcern(WriteConcern.MAJORITY);
     }
 

plugins-it/mongodb-it/src/test/java/com/navercorp/pinpoint/plugin/mongodb/MongodServer.java

@@ -1,5 +1,6 @@
 package com.navercorp.pinpoint.plugin.mongodb;
 
+import com.navercorp.pinpoint.testcase.util.SocketUtils;
 import de.flapdoodle.embed.mongo.MongodExecutable;
 import de.flapdoodle.embed.mongo.MongodProcess;
 import de.flapdoodle.embed.mongo.MongodStarter;
@@ -27,12 +28,14 @@ public class MongodServer {
     private final MongodExecutable mongodExecutable;
     private MongodProcess mongod;
 
+    private final int port = SocketUtils.findAvailableTcpPort(MongoDBITConstants.DEFAULT_PORT);
+
     public MongodServer() throws IOException {
         MongodStarter starter = newStarter();
 
         MongodConfig mongodConfig = MongodConfig.builder()
                 .version(Version.Main.V4_4)
-                .net(new Net(MongoDBITConstants.BIND_ADDRESS, MongoDBITConstants.PORT, Network.localhostIsIPv6()))
+                .net(new Net(MongoDBITConstants.BIND_ADDRESS, port, Network.localhostIsIPv6()))
                 .build();
         this.mongodExecutable = starter.prepare(mongodConfig);
     }
@@ -41,6 +44,14 @@ public void start() throws IOException {
         mongod = mongodExecutable.start();
     }
 
+    public int getPort() {
+        return port;
+    }
+
+    public String getAddress() {
+        return MongoDBITConstants.BIND_ADDRESS + ":" + port;
+    }
+
     private String getTempPath() throws IOException {
         URL resource = MongoDBITBase.class.getProtectionDomain().getCodeSource().getLocation();
         if (resource == null) {