From 02e0b14dfd434ea86a8bdb5c7081fd45e80336ec Mon Sep 17 00:00:00 2001 From: Clebert Suconic Date: Mon, 21 Oct 2024 10:36:49 -0400 Subject: [PATCH] ARTEMIS-5118 Expose HelperCreate on the CLI Jar --- .../artemis/cli/commands}/helper/HelperBase.java | 10 +++++----- .../artemis/cli/commands}/helper/HelperCreate.java | 10 +++++----- .../activemq/artemis/utils/RealServerTestBase.java | 7 +++++++ .../compatibility/distribution/RollingUpgradeTest.java | 8 ++++---- .../smoke/bridgeTransfer/BridgeTransferingTest.java | 6 +++--- .../BrokerConnectionBridgeSecurityTest.java | 6 +++--- .../BrokerConnectionMirrorSecurityTest.java | 6 +++--- .../smoke/brokerConnection/DivertQueueMirrorTest.java | 4 ++-- .../smoke/brokerConnection/DualFederationTest.java | 6 +++--- .../brokerConnection/DualMirrorNoContainerTest.java | 6 +++--- .../MirrorInfiniteRetryReplicaTest.java | 6 +++--- .../brokerConnection/MirroredSubscriptionTest.java | 6 +++--- .../smoke/brokerConnection/PagedMirrorSmokeTest.java | 6 +++--- .../artemis/tests/smoke/checkTest/CheckTest.java | 6 +++--- .../ClusteredLargeMessageTest.java | 6 +++--- .../tests/smoke/console/ConsoleMutualSSLTest.java | 4 ++-- .../smoke/crossprotocol/MultiThreadConvertTest.java | 4 ++-- .../artemis/tests/smoke/custometc/CustomETCTest.java | 4 ++-- .../artemis/tests/smoke/expire/TestSimpleExpire.java | 4 ++-- .../smoke/infinite/InfiniteRedeliverySmokeTest.java | 4 ++-- .../tests/smoke/jdbccli/JDBCExportWrongUserTest.java | 4 ++-- .../artemis/tests/smoke/jmx/JmxConnectionTest.java | 4 ++-- .../artemis/tests/smoke/jmx2/JmxServerControlTest.java | 4 ++-- .../tests/smoke/jmxfailback/JmxFailbackTest.java | 6 +++--- .../ReplicatedMultipleFailbackTest.java | 10 +++++----- .../tests/smoke/jmxrbac/JmxRBACBrokerSecurityTest.java | 4 ++-- .../artemis/tests/smoke/jmxrbac/JmxRBACTest.java | 4 ++-- .../smoke/lockmanager/LockManagerSinglePairTest.java | 4 ++-- .../tests/smoke/logging/AuditLoggerTestBase.java | 4 ++-- .../tests/smoke/maxConsumers/MaxConsumersTest.java | 4 ++-- .../artemis/tests/smoke/mqtt/MQTTLeakTest.java | 4 ++-- .../tests/smoke/nettynative/NettyNativeTest.java | 4 ++-- .../smoke/paging/FloodServerWithAsyncSendTest.java | 4 ++-- .../tests/smoke/paging/SmokeMaxMessagePagingTest.java | 6 +++--- .../artemis/tests/smoke/paging/SmokePagingTest.java | 4 ++-- .../tests/smoke/resourcetest/MaxQueueResourceTest.java | 4 ++-- .../artemis/tests/smoke/retention/ReplayTest.java | 4 ++-- .../tests/smoke/topologycheck/TopologyCheckTest.java | 4 ++-- .../artemis/tests/smoke/transfer/TransferTest.java | 6 +++--- .../mirror/AccumulatedInPageSoakTest.java | 4 ++-- .../mirror/ClusteredMirrorSoakTest.java | 4 ++-- .../brokerConnection/mirror/DivertSoakMirrorTest.java | 4 ++-- .../brokerConnection/mirror/IdempotentACKTest.java | 4 ++-- .../mirror/InterruptedLargeMessageTest.java | 4 ++-- .../brokerConnection/mirror/MultiMirrorSoakTest.java | 4 ++-- .../soak/brokerConnection/mirror/PagedSNFSoakTest.java | 4 ++-- .../mirror/ReplicatedBothNodesMirrorTest.java | 6 +++--- .../mirror/ReplicatedMirrorTargetTest.java | 6 +++--- .../brokerConnection/mirror/SingleMirrorSoakTest.java | 4 ++-- .../soak/brokerConnection/sender/SenderSoakTest.java | 4 ++-- .../soak/clientFailure/ClientFailureSoakTest.java | 4 ++-- .../ClusterNotificationsContinuityTest.java | 4 ++-- .../soak/interrupt/JournalFlushInterruptTest.java | 4 ++-- .../ClusteredLargeMessageInterruptTest.java | 6 +++--- .../soak/interruptlm/LargeMessageInterruptTest.java | 4 ++-- .../artemis/tests/soak/mqtt/MQTT5SoakTest.java | 4 ++-- .../activemq/artemis/tests/soak/owleak/OWLeakTest.java | 4 ++-- .../tests/soak/paging/FlowControlPagingTest.java | 4 ++-- .../tests/soak/paging/HorizontalPagingTest.java | 4 ++-- .../artemis/tests/soak/paging/M_and_M_FactoryTest.java | 4 ++-- .../tests/soak/paging/SubscriptionPagingTest.java | 4 ++-- .../tests/soak/paging/ValidateExportSpeedTest.java | 4 ++-- .../tests/soak/replicaTxCheck/ReplicaTXCheckTest.java | 4 ++-- .../replicationflow/ReplicationFlowControlTest.java | 6 +++--- .../soak/replicationflow/SoakReplicatedPagingTest.java | 6 +++--- .../soak/retention/LargeMessageRetentionTest.java | 4 ++-- .../artemis/tests/soak/stomp/StompSoakTest.java | 4 ++-- 67 files changed, 168 insertions(+), 161 deletions(-) rename {tests/artemis-test-support/src/main/java/org/apache/activemq/artemis/utils/cli => artemis-cli/src/main/java/org/apache/activemq/artemis/cli/commands}/helper/HelperBase.java (92%) rename {tests/artemis-test-support/src/main/java/org/apache/activemq/artemis/utils/cli => artemis-cli/src/main/java/org/apache/activemq/artemis/cli/commands}/helper/HelperCreate.java (98%) diff --git a/tests/artemis-test-support/src/main/java/org/apache/activemq/artemis/utils/cli/helper/HelperBase.java b/artemis-cli/src/main/java/org/apache/activemq/artemis/cli/commands/helper/HelperBase.java similarity index 92% rename from tests/artemis-test-support/src/main/java/org/apache/activemq/artemis/utils/cli/helper/HelperBase.java rename to artemis-cli/src/main/java/org/apache/activemq/artemis/cli/commands/helper/HelperBase.java index 8444ff5456a..0fe2b91f274 100644 --- a/tests/artemis-test-support/src/main/java/org/apache/activemq/artemis/utils/cli/helper/HelperBase.java +++ b/artemis-cli/src/main/java/org/apache/activemq/artemis/cli/commands/helper/HelperBase.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package org.apache.activemq.artemis.utils.cli.helper; +package org.apache.activemq.artemis.cli.commands.helper; import java.io.File; import java.lang.invoke.MethodHandles; @@ -27,8 +27,6 @@ public class HelperBase { private static final Logger logger = LoggerFactory.getLogger(MethodHandles.lookup().lookupClass()); - public static final String ARTEMIS_HOME_PROPERTY = "artemis.distribution.output"; - File artemisHome; File artemisInstance; @@ -37,10 +35,12 @@ public class HelperBase { logger.debug("using artemisHome as {}", artemisHome); } - public static File getHome() { - return getHome(ARTEMIS_HOME_PROPERTY); + HelperBase(File artemisHome) { + setArtemisHome(artemisHome); + logger.debug("using artemisHome as {}", artemisHome); } + public static File getHome(String homeProperty) { String valueHome = System.getProperty(homeProperty); if (valueHome == null) { diff --git a/tests/artemis-test-support/src/main/java/org/apache/activemq/artemis/utils/cli/helper/HelperCreate.java b/artemis-cli/src/main/java/org/apache/activemq/artemis/cli/commands/helper/HelperCreate.java similarity index 98% rename from tests/artemis-test-support/src/main/java/org/apache/activemq/artemis/utils/cli/helper/HelperCreate.java rename to artemis-cli/src/main/java/org/apache/activemq/artemis/cli/commands/helper/HelperCreate.java index 293138e186a..23501f233f3 100644 --- a/tests/artemis-test-support/src/main/java/org/apache/activemq/artemis/utils/cli/helper/HelperCreate.java +++ b/artemis-cli/src/main/java/org/apache/activemq/artemis/cli/commands/helper/HelperCreate.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package org.apache.activemq.artemis.utils.cli.helper; +package org.apache.activemq.artemis.cli.commands.helper; import java.io.File; import java.io.IOException; @@ -36,14 +36,14 @@ * You may use by creating a new instance, filling the properties, and calling the method create */ public class HelperCreate extends HelperBase { - public HelperCreate() { - super(ARTEMIS_HOME_PROPERTY); - } - public HelperCreate(String homeProperty) { super(homeProperty); } + public HelperCreate(File artemisHome) { + super(artemisHome); + } + private static final Logger logger = LoggerFactory.getLogger(MethodHandles.lookup().lookupClass()); private File configuration; diff --git a/tests/artemis-test-support/src/main/java/org/apache/activemq/artemis/utils/RealServerTestBase.java b/tests/artemis-test-support/src/main/java/org/apache/activemq/artemis/utils/RealServerTestBase.java index b7d2f46373a..e8aea1aa996 100644 --- a/tests/artemis-test-support/src/main/java/org/apache/activemq/artemis/utils/RealServerTestBase.java +++ b/tests/artemis-test-support/src/main/java/org/apache/activemq/artemis/utils/RealServerTestBase.java @@ -46,6 +46,7 @@ import org.apache.activemq.artemis.api.core.management.QueueControl; import org.apache.activemq.artemis.api.core.management.SimpleManagement; import org.apache.activemq.artemis.api.jms.ActiveMQJMSClient; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory; import org.apache.activemq.artemis.tests.util.ActiveMQTestBase; import org.apache.activemq.artemis.util.ServerUtil; @@ -65,6 +66,12 @@ public class RealServerTestBase extends ActiveMQTestBase { public static final String basedir = System.getProperty("basedir"); + public static final String ARTEMIS_HOME_PROPERTY = "artemis.distribution.output"; + + public static HelperCreate helperCreate() { + return new HelperCreate(ARTEMIS_HOME_PROPERTY); + } + @AfterEach public void after() throws Exception { // close ServerLocators before killing the server otherwise they'll hang and delay test termination diff --git a/tests/compatibility-tests/src/test/java/org/apache/activemq/artemis/tests/compatibility/distribution/RollingUpgradeTest.java b/tests/compatibility-tests/src/test/java/org/apache/activemq/artemis/tests/compatibility/distribution/RollingUpgradeTest.java index 47928af1819..cb5ff18e437 100644 --- a/tests/compatibility-tests/src/test/java/org/apache/activemq/artemis/tests/compatibility/distribution/RollingUpgradeTest.java +++ b/tests/compatibility-tests/src/test/java/org/apache/activemq/artemis/tests/compatibility/distribution/RollingUpgradeTest.java @@ -37,7 +37,7 @@ import org.apache.activemq.artemis.utils.SpawnedVMSupport; import org.apache.activemq.artemis.utils.TestParameters; import org.apache.activemq.artemis.utils.Wait; -import org.apache.activemq.artemis.utils.cli.helper.HelperBase; +import org.apache.activemq.artemis.cli.commands.helper.HelperBase; import org.junit.jupiter.api.Test; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -184,12 +184,12 @@ private void upgrade(File home, File instance) throws Exception { @Test public void testRollUpgrade_2_30() throws Exception { - testRollUpgrade(new File(TWO_THIRTY), HelperBase.getHome()); + testRollUpgrade(new File(TWO_THIRTY), HelperBase.getHome(ARTEMIS_HOME_PROPERTY)); } @Test public void testRollUpgrade_2_36() throws Exception { - testRollUpgrade(new File(TWO_THIRTY_SIX), HelperBase.getHome()); + testRollUpgrade(new File(TWO_THIRTY_SIX), HelperBase.getHome(ARTEMIS_HOME_PROPERTY)); } // Define a System Property TEST_ROLLED_DISTRIBUTION towards the Artemis Home of your choice and this will @@ -200,7 +200,7 @@ public void testRollUpgrade_Provided_Distribution() throws Exception { String distribution = TestParameters.testProperty("ROLLED", "DISTRIBUTION", null); assumeTrue(distribution != null); - String distributionUpgrading = TestParameters.testProperty("ROLLED", "DISTRIBUTION_UPGRADE", HelperBase.getHome().getAbsolutePath()); + String distributionUpgrading = TestParameters.testProperty("ROLLED", "DISTRIBUTION_UPGRADE", HelperBase.getHome(ARTEMIS_HOME_PROPERTY).getAbsolutePath()); testRollUpgrade(new File(distribution), new File(distributionUpgrading)); } diff --git a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/bridgeTransfer/BridgeTransferingTest.java b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/bridgeTransfer/BridgeTransferingTest.java index b75590c421f..dfca8d56118 100644 --- a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/bridgeTransfer/BridgeTransferingTest.java +++ b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/bridgeTransfer/BridgeTransferingTest.java @@ -38,7 +38,7 @@ import org.apache.activemq.artemis.tests.smoke.common.SmokeTestBase; import org.apache.activemq.artemis.tests.util.CFUtil; import org.apache.activemq.artemis.utils.Wait; -import org.apache.activemq.artemis.utils.cli.helper.HelperCreate; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.junit.jupiter.api.AfterEach; import org.junit.jupiter.api.BeforeAll; import org.junit.jupiter.api.BeforeEach; @@ -61,13 +61,13 @@ public static void createServers() throws Exception { deleteDirectory(server0Location); if (!server0Location.exists()) { - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setRole("amq").setUser("artemis").setPassword("artemis").setNoWeb(true).setConfiguration("./src/main/resources/servers/bridgeTransfer/serverA").setArtemisInstance(server0Location); cliCreateServer.createServer(); } if (!server1Location.exists()) { - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setRole("amq").setUser("artemis").setPassword("artemis").setNoWeb(true).setConfiguration("./src/main/resources/servers/bridgeTransfer/serverB").setArtemisInstance(server1Location); cliCreateServer.createServer(); } diff --git a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/brokerConnection/BrokerConnectionBridgeSecurityTest.java b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/brokerConnection/BrokerConnectionBridgeSecurityTest.java index d7554a0c970..4cebfa8af0a 100644 --- a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/brokerConnection/BrokerConnectionBridgeSecurityTest.java +++ b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/brokerConnection/BrokerConnectionBridgeSecurityTest.java @@ -33,7 +33,7 @@ import org.apache.activemq.artemis.tests.smoke.common.SmokeTestBase; import org.apache.activemq.artemis.util.ServerUtil; -import org.apache.activemq.artemis.utils.cli.helper.HelperCreate; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.junit.jupiter.api.BeforeAll; import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.Test; @@ -51,13 +51,13 @@ public static void createServers() throws Exception { { - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setAllowAnonymous(false).setUser("A").setPassword("A").setNoWeb(true).setConfiguration("./src/main/resources/servers/brokerConnect/bridgeSecurityA").setArtemisInstance(server0Location); cliCreateServer.createServer(); } { - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setAllowAnonymous(false).setUser("A").setPassword("A").setNoWeb(true).setConfiguration("./src/main/resources/servers/brokerConnect/bridgeSecurityB").setArtemisInstance(server1Location); cliCreateServer.createServer(); } diff --git a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/brokerConnection/BrokerConnectionMirrorSecurityTest.java b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/brokerConnection/BrokerConnectionMirrorSecurityTest.java index 31e91adb781..63104ea52b6 100644 --- a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/brokerConnection/BrokerConnectionMirrorSecurityTest.java +++ b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/brokerConnection/BrokerConnectionMirrorSecurityTest.java @@ -33,7 +33,7 @@ import org.apache.activemq.artemis.tests.smoke.common.SmokeTestBase; import org.apache.activemq.artemis.tests.util.CFUtil; import org.apache.activemq.artemis.util.ServerUtil; -import org.apache.activemq.artemis.utils.cli.helper.HelperCreate; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.junit.jupiter.api.BeforeAll; import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.Test; @@ -52,13 +52,13 @@ public static void createServers() throws Exception { deleteDirectory(server0Location); { - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setAllowAnonymous(false).setUser("A").setPassword("A").setNoWeb(true).setConfiguration("./src/main/resources/servers/brokerConnect/mirrorSecurityA").setArtemisInstance(server0Location); cliCreateServer.createServer(); } { - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setAllowAnonymous(false).setUser("B").setPassword("B").setNoWeb(true).setPortOffset(1).setConfiguration("./src/main/resources/servers/brokerConnect/mirrorSecurityB").setArtemisInstance(server1Location); cliCreateServer.createServer(); } diff --git a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/brokerConnection/DivertQueueMirrorTest.java b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/brokerConnection/DivertQueueMirrorTest.java index e966980aeca..9cadc608aa4 100644 --- a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/brokerConnection/DivertQueueMirrorTest.java +++ b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/brokerConnection/DivertQueueMirrorTest.java @@ -36,7 +36,7 @@ import org.apache.activemq.artemis.tests.util.CFUtil; import org.apache.activemq.artemis.util.ServerUtil; import org.apache.activemq.artemis.utils.Wait; -import org.apache.activemq.artemis.utils.cli.helper.HelperCreate; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.junit.jupiter.api.Assertions; import org.junit.jupiter.api.BeforeAll; import org.junit.jupiter.api.BeforeEach; @@ -79,7 +79,7 @@ private static void createServer(String serverName, File serverLocation = getFileServerLocation(serverName); deleteDirectory(serverLocation); - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setAllowAnonymous(true).setNoWeb(true).setArtemisInstance(serverLocation); cliCreateServer.setMessageLoadBalancing("ON_DEMAND"); cliCreateServer.setClustered(false); diff --git a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/brokerConnection/DualFederationTest.java b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/brokerConnection/DualFederationTest.java index 4cbb27f1639..502efd03ffb 100644 --- a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/brokerConnection/DualFederationTest.java +++ b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/brokerConnection/DualFederationTest.java @@ -33,7 +33,7 @@ import org.apache.activemq.artemis.tests.smoke.common.SmokeTestBase; import org.apache.activemq.artemis.tests.util.CFUtil; import org.apache.activemq.artemis.util.ServerUtil; -import org.apache.activemq.artemis.utils.cli.helper.HelperCreate; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.junit.jupiter.api.BeforeAll; import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.Test; @@ -52,13 +52,13 @@ public static void createServers() throws Exception { deleteDirectory(server0Location); { - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setAllowAnonymous(true).setUser("A").setPassword("A").setRole("amq").setNoWeb(true).setConfiguration("./src/main/resources/servers/brokerConnect/federationA").setArtemisInstance(server0Location); cliCreateServer.createServer(); } { - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setAllowAnonymous(true).setUser("B").setPassword("B").setRole("amq").setNoWeb(true).setPortOffset(1).setConfiguration("./src/main/resources/servers/brokerConnect/federationB").setArtemisInstance(server1Location); cliCreateServer.createServer(); } diff --git a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/brokerConnection/DualMirrorNoContainerTest.java b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/brokerConnection/DualMirrorNoContainerTest.java index e342119a1be..221f5c92aa1 100644 --- a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/brokerConnection/DualMirrorNoContainerTest.java +++ b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/brokerConnection/DualMirrorNoContainerTest.java @@ -36,11 +36,11 @@ import java.io.FileOutputStream; import java.io.PrintStream; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.apache.activemq.artemis.cli.commands.tools.PrintData; import org.apache.activemq.artemis.tests.smoke.common.SmokeTestBase; import org.apache.activemq.artemis.tests.util.CFUtil; import org.apache.activemq.artemis.util.ServerUtil; -import org.apache.activemq.artemis.utils.cli.helper.HelperCreate; import org.junit.jupiter.api.BeforeAll; import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.Test; @@ -65,13 +65,13 @@ public static void createServers() throws Exception { deleteDirectory(server0Location); { - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setAllowAnonymous(false).setUser("A").setPassword("A").setNoWeb(true).setConfiguration("./src/main/resources/servers/brokerConnect/mirrorSecurityA").setArtemisInstance(server0Location); cliCreateServer.createServer(); } { - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setAllowAnonymous(false).setUser("B").setPassword("B").setNoWeb(true).setPortOffset(1).setConfiguration("./src/main/resources/servers/brokerConnect/mirrorSecurityB").setArtemisInstance(server1Location); cliCreateServer.createServer(); } diff --git a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/brokerConnection/MirrorInfiniteRetryReplicaTest.java b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/brokerConnection/MirrorInfiniteRetryReplicaTest.java index 6025fc679ae..7a18f8685f7 100644 --- a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/brokerConnection/MirrorInfiniteRetryReplicaTest.java +++ b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/brokerConnection/MirrorInfiniteRetryReplicaTest.java @@ -35,7 +35,7 @@ import org.apache.activemq.artemis.util.ServerUtil; import org.apache.activemq.artemis.utils.FileUtil; import org.apache.activemq.artemis.utils.Wait; -import org.apache.activemq.artemis.utils.cli.helper.HelperCreate; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.junit.jupiter.api.AfterEach; import org.junit.jupiter.api.Test; @@ -110,7 +110,7 @@ private static void createMirroredServer(String serverName, File serverLocation = getFileServerLocation(serverName); deleteDirectory(serverLocation); - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setAllowAnonymous(true).setArtemisInstance(serverLocation); cliCreateServer.setNoWeb(true); cliCreateServer.setArgs("--no-stomp-acceptor", "--no-hornetq-acceptor", "--no-mqtt-acceptor", "--no-amqp-acceptor", "--max-hops", "1", "--name", DC1_NODE); @@ -174,7 +174,7 @@ private static void createMirroredBackupServer(String serverName, File serverLocation = getFileServerLocation(serverName); deleteDirectory(serverLocation); - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setAllowAnonymous(true).setArtemisInstance(serverLocation); cliCreateServer.setMessageLoadBalancing("ON_DEMAND"); cliCreateServer.setArgs("--no-stomp-acceptor", "--no-hornetq-acceptor", "--no-mqtt-acceptor", "--no-amqp-acceptor", "--max-hops", "1", "--name", DC1_NODE); diff --git a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/brokerConnection/MirroredSubscriptionTest.java b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/brokerConnection/MirroredSubscriptionTest.java index f607ba8f7ff..4186c9a96d4 100644 --- a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/brokerConnection/MirroredSubscriptionTest.java +++ b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/brokerConnection/MirroredSubscriptionTest.java @@ -42,7 +42,7 @@ import org.apache.activemq.artemis.tests.util.CFUtil; import org.apache.activemq.artemis.util.ServerUtil; import org.apache.activemq.artemis.utils.Wait; -import org.apache.activemq.artemis.utils.cli.helper.HelperCreate; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.junit.jupiter.api.BeforeAll; import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.Test; @@ -64,13 +64,13 @@ public static void createServers() throws Exception { deleteDirectory(server0Location); { - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setAllowAnonymous(true).setRole("amq").setUser("admin").setPassword("admin").setNoWeb(true).setConfiguration("./src/main/resources/servers/mirrored-subscriptions/broker1").setArtemisInstance(server0Location); cliCreateServer.createServer(); } { - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setAllowAnonymous(true).setRole("amq").setUser("admin").setPassword("admin").setNoWeb(true).setConfiguration("./src/main/resources/servers/mirrored-subscriptions/broker2").setArtemisInstance(server1Location); cliCreateServer.createServer(); } diff --git a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/brokerConnection/PagedMirrorSmokeTest.java b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/brokerConnection/PagedMirrorSmokeTest.java index 15e7d55f4b0..8fa67b46018 100644 --- a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/brokerConnection/PagedMirrorSmokeTest.java +++ b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/brokerConnection/PagedMirrorSmokeTest.java @@ -35,7 +35,7 @@ import org.apache.activemq.artemis.tests.util.CFUtil; import org.apache.activemq.artemis.utils.Wait; import org.apache.activemq.artemis.util.ServerUtil; -import org.apache.activemq.artemis.utils.cli.helper.HelperCreate; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.junit.jupiter.api.BeforeAll; import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.Test; @@ -61,13 +61,13 @@ public static void createServers() throws Exception { deleteDirectory(server0Location); if (!server0Location.exists()) { - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setAllowAnonymous(true).setRole("amq").setUser("artemis").setPassword("artemis").setNoWeb(true).setConfiguration("./src/main/resources/servers/brokerConnect/pagedA").setArtemisInstance(server0Location); cliCreateServer.createServer(); } if (!server1Location.exists()) { - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setAllowAnonymous(true).setRole("amq").setUser("artemis").setPassword("artemis").setNoWeb(true).setConfiguration("./src/main/resources/servers/brokerConnect/pagedB").setArtemisInstance(server1Location); cliCreateServer.createServer(); } diff --git a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/checkTest/CheckTest.java b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/checkTest/CheckTest.java index 0d4f45bac53..00d3653592c 100644 --- a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/checkTest/CheckTest.java +++ b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/checkTest/CheckTest.java @@ -46,7 +46,7 @@ import org.apache.activemq.artemis.util.ServerUtil; import org.apache.activemq.artemis.utils.RandomUtil; import org.apache.activemq.artemis.utils.Wait; -import org.apache.activemq.artemis.utils.cli.helper.HelperCreate; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.junit.jupiter.api.BeforeAll; import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.Test; @@ -72,13 +72,13 @@ public static void createServers() throws Exception { deleteDirectory(server0Location); { - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setSharedStore(true).setBackup(false).setSharedStore(true).setDataFolder("./target/check-test/data").setFailoverOnShutdown(true).setStaticCluster("tcp://localhost:61716").setArtemisInstance(server0Location); cliCreateServer.createServer(); } { - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setSharedStore(true).setBackup(true).setSharedStore(true).setDataFolder("./target/check-test/data").setFailoverOnShutdown(true).setStaticCluster("tcp://localhost:61616").setPortOffset(100).setArtemisInstance(server1Location); cliCreateServer.createServer(); } diff --git a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/clusteredLargeMessage/ClusteredLargeMessageTest.java b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/clusteredLargeMessage/ClusteredLargeMessageTest.java index 56e4f4a0500..271f0daf5ca 100644 --- a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/clusteredLargeMessage/ClusteredLargeMessageTest.java +++ b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/clusteredLargeMessage/ClusteredLargeMessageTest.java @@ -35,7 +35,7 @@ import org.apache.activemq.artemis.tests.util.CFUtil; import org.apache.activemq.artemis.util.ServerUtil; import org.apache.activemq.artemis.utils.Wait; -import org.apache.activemq.artemis.utils.cli.helper.HelperCreate; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.junit.jupiter.api.BeforeAll; import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.Test; @@ -51,14 +51,14 @@ public static void createServers() throws Exception { deleteDirectory(server0Location); { - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setRole("amq").setUser("artemis").setPassword("artemis").setAllowAnonymous(true).setNoWeb(true). setArtemisInstance(server0Location).setClustered(true). setStaticCluster("tcp://localhost:61716").setArgs("--name", "cluster1", "--max-hops", "1", "--queues", "testQueue"); cliCreateServer.createServer(); } { - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setRole("amq").setUser("artemis").setPassword("artemis").setAllowAnonymous(true).setNoWeb(true).setPortOffset(100). setArtemisInstance(server1Location).setClustered(true). setStaticCluster("tcp://localhost:61616").setArgs("--name", "cluster2", "--max-hops", "1", "--queues", "testQueue"); diff --git a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/console/ConsoleMutualSSLTest.java b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/console/ConsoleMutualSSLTest.java index c28662d5509..bf140b03083 100644 --- a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/console/ConsoleMutualSSLTest.java +++ b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/console/ConsoleMutualSSLTest.java @@ -20,7 +20,7 @@ import org.apache.activemq.artemis.tests.smoke.common.SmokeTestBase; import org.apache.activemq.artemis.util.ServerUtil; import org.apache.activemq.artemis.utils.Wait; -import org.apache.activemq.artemis.utils.cli.helper.HelperCreate; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.apache.http.client.methods.CloseableHttpResponse; import org.apache.http.client.methods.HttpGet; import org.apache.http.impl.client.CloseableHttpClient; @@ -42,7 +42,7 @@ public class ConsoleMutualSSLTest extends SmokeTestBase { public static void createServers() throws Exception { File server0Location = getFileServerLocation(SERVER_NAME); deleteDirectory(server0Location); - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setRole("amq").setUser("admin").setPassword("admin").setAllowAnonymous(false).setConfiguration("./src/main/resources/servers/console-mutual-ssl"). setNoWeb(false).setArtemisInstance(server0Location).setArgs( "--http-host", "localhost", diff --git a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/crossprotocol/MultiThreadConvertTest.java b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/crossprotocol/MultiThreadConvertTest.java index 01a85114238..aff03270f43 100644 --- a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/crossprotocol/MultiThreadConvertTest.java +++ b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/crossprotocol/MultiThreadConvertTest.java @@ -43,7 +43,7 @@ import org.apache.activemq.artemis.core.server.ActiveMQServer; import org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory; import org.apache.activemq.artemis.tests.smoke.common.SmokeTestBase; -import org.apache.activemq.artemis.utils.cli.helper.HelperCreate; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.apache.qpid.jms.JmsConnectionFactory; import org.junit.jupiter.api.AfterEach; import org.junit.jupiter.api.BeforeAll; @@ -67,7 +67,7 @@ public static void createServers() throws Exception { deleteDirectory(server0Location); { - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setUser("admin").setPassword("admin").setAllowAnonymous(true).setNoWeb(true). setArtemisInstance(server0Location); cliCreateServer.createServer(); diff --git a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/custometc/CustomETCTest.java b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/custometc/CustomETCTest.java index 8be191406e9..5c8558a3b52 100644 --- a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/custometc/CustomETCTest.java +++ b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/custometc/CustomETCTest.java @@ -35,7 +35,7 @@ import org.apache.activemq.artemis.tests.smoke.common.SmokeTestBase; import org.apache.activemq.artemis.tests.util.CFUtil; import org.apache.activemq.artemis.utils.RandomUtil; -import org.apache.activemq.artemis.utils.cli.helper.HelperCreate; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.junit.jupiter.api.BeforeAll; import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.Test; @@ -51,7 +51,7 @@ public static void createServers() throws Exception { deleteDirectory(server0Location); { - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setUser("admin").setPassword("admin").setAllowAnonymous(true).setNoWeb(true). setArgs("--etc", new File("./target/customETC/theCustomETC").getAbsolutePath()). setArtemisInstance(server0Location); diff --git a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/expire/TestSimpleExpire.java b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/expire/TestSimpleExpire.java index 00dd00541b9..7365c60f623 100644 --- a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/expire/TestSimpleExpire.java +++ b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/expire/TestSimpleExpire.java @@ -32,7 +32,7 @@ import java.io.File; import org.apache.activemq.artemis.tests.smoke.common.SmokeTestBase; -import org.apache.activemq.artemis.utils.cli.helper.HelperCreate; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.apache.qpid.jms.JmsConnectionFactory; import org.junit.jupiter.api.BeforeAll; import org.junit.jupiter.api.BeforeEach; @@ -49,7 +49,7 @@ public static void createServers() throws Exception { deleteDirectory(server0Location); { - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setUser("admin").setPassword("admin").setAllowAnonymous(true).setNoWeb(true).setArtemisInstance(server0Location).setArgs("--disable-persistence"); cliCreateServer.createServer(); } diff --git a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/infinite/InfiniteRedeliverySmokeTest.java b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/infinite/InfiniteRedeliverySmokeTest.java index 8bb9d2aa6cf..b99bc14fb45 100644 --- a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/infinite/InfiniteRedeliverySmokeTest.java +++ b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/infinite/InfiniteRedeliverySmokeTest.java @@ -35,7 +35,7 @@ import org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory; import org.apache.activemq.artemis.tests.smoke.common.SmokeTestBase; import org.apache.activemq.artemis.utils.Wait; -import org.apache.activemq.artemis.utils.cli.helper.HelperCreate; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.junit.jupiter.api.BeforeAll; import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.Test; @@ -56,7 +56,7 @@ public static void createServers() throws Exception { deleteDirectory(server0Location); { - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setUser("admin").setPassword("admin").setAllowAnonymous(true).setNoWeb(true).setArtemisInstance(server0Location).setConfiguration("./src/main/resources/servers/infinite-redelivery"); cliCreateServer.createServer(); } diff --git a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/jdbccli/JDBCExportWrongUserTest.java b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/jdbccli/JDBCExportWrongUserTest.java index 1916b0c48ab..2ec00498c98 100644 --- a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/jdbccli/JDBCExportWrongUserTest.java +++ b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/jdbccli/JDBCExportWrongUserTest.java @@ -28,7 +28,7 @@ import org.apache.activemq.artemis.tests.smoke.common.SmokeTestBase; import org.apache.activemq.artemis.utils.FileUtil; import org.apache.activemq.artemis.utils.RandomUtil; -import org.apache.activemq.artemis.utils.cli.helper.HelperCreate; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.junit.jupiter.api.Test; public class JDBCExportWrongUserTest extends SmokeTestBase { @@ -43,7 +43,7 @@ public void testUserNameAndPasswordCaptured() throws Exception { runAfter(() -> deleteDirectory(server0Location)); - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setUser("admin").setPassword("admin").setAllowAnonymous(true).setNoWeb(true).setArtemisInstance(server0Location).addArgs("--jdbc", "--jdbc-connection-url", "fakeOne"); cliCreateServer.createServer(); diff --git a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/jmx/JmxConnectionTest.java b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/jmx/JmxConnectionTest.java index 1cbdea14043..eb9996bc3aa 100644 --- a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/jmx/JmxConnectionTest.java +++ b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/jmx/JmxConnectionTest.java @@ -36,7 +36,7 @@ import io.netty.util.internal.PlatformDependent; import org.apache.activemq.artemis.tests.smoke.common.SmokeTestBase; -import org.apache.activemq.artemis.utils.cli.helper.HelperCreate; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.jctools.util.UnsafeAccess; import org.junit.jupiter.api.BeforeAll; import org.junit.jupiter.api.BeforeEach; @@ -64,7 +64,7 @@ public static void createServers() throws Exception { deleteDirectory(server0Location); { - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setUser("admin").setPassword("admin").setAllowAnonymous(true).setNoWeb(true).setArtemisInstance(server0Location). setConfiguration("./src/main/resources/servers/jmx").setArgs("--java-options", "-Djava.rmi.server.hostname=localhost"); cliCreateServer.createServer(); diff --git a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/jmx2/JmxServerControlTest.java b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/jmx2/JmxServerControlTest.java index d70a6db6ca6..31803317f6c 100644 --- a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/jmx2/JmxServerControlTest.java +++ b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/jmx2/JmxServerControlTest.java @@ -42,7 +42,7 @@ import org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory; import org.apache.activemq.artemis.jms.client.ActiveMQQueue; import org.apache.activemq.artemis.tests.smoke.common.SmokeTestBase; -import org.apache.activemq.artemis.utils.cli.helper.HelperCreate; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.junit.jupiter.api.BeforeAll; import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.Test; @@ -62,7 +62,7 @@ public static void createServers() throws Exception { deleteDirectory(server0Location); { - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setUser("admin").setPassword("admin").setAllowAnonymous(true).setNoWeb(true).setArtemisInstance(server0Location). setConfiguration("./src/main/resources/servers/jmx").setArgs("--java-options", "-Djava.rmi.server.hostname=localhost -Dcom.sun.management.jmxremote=true " + diff --git a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/jmxfailback/JmxFailbackTest.java b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/jmxfailback/JmxFailbackTest.java index 9f0ecdef916..05aaf6e7627 100644 --- a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/jmxfailback/JmxFailbackTest.java +++ b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/jmxfailback/JmxFailbackTest.java @@ -30,7 +30,7 @@ import org.apache.activemq.artemis.api.core.management.ObjectNameBuilder; import org.apache.activemq.artemis.tests.smoke.common.SmokeTestBase; import org.apache.activemq.artemis.utils.Wait; -import org.apache.activemq.artemis.utils.cli.helper.HelperCreate; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.junit.jupiter.api.BeforeAll; import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.Test; @@ -54,14 +54,14 @@ public static void createServers() throws Exception { deleteDirectory(server1Location); { - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setUser("admin").setPassword("admin").setAllowAnonymous(true).setNoWeb(true).setArtemisInstance(server0Location). setConfiguration("./src/main/resources/servers/jmx-failback1").setArgs( "--java-options", "-Djava.rmi.server.hostname=localhost"); cliCreateServer.createServer(); } { - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setUser("admin").setPassword("admin").setAllowAnonymous(true).setNoWeb(true).setArtemisInstance(server1Location). setConfiguration("./src/main/resources/servers/jmx-failback2").setArgs( "--java-options", "-Djava.rmi.server.hostname=localhost"); cliCreateServer.createServer(); diff --git a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/jmxmultiplefailback/ReplicatedMultipleFailbackTest.java b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/jmxmultiplefailback/ReplicatedMultipleFailbackTest.java index 259bb7ed8e8..0876e97d2b5 100644 --- a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/jmxmultiplefailback/ReplicatedMultipleFailbackTest.java +++ b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/jmxmultiplefailback/ReplicatedMultipleFailbackTest.java @@ -47,7 +47,7 @@ import org.apache.activemq.artemis.tests.smoke.common.SmokeTestBase; import org.apache.activemq.artemis.utils.JsonLoader; import org.apache.activemq.artemis.utils.Wait; -import org.apache.activemq.artemis.utils.cli.helper.HelperCreate; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.junit.jupiter.api.BeforeAll; import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.Test; @@ -193,25 +193,25 @@ public static void createServers() throws Exception { deleteDirectory(server3Location); { - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setUser("admin").setPassword("admin").setAllowAnonymous(true).setNoWeb(true).setArtemisInstance(server0Location).setConfiguration("./src/main/resources/servers/replicated-failback-primary1").setArgs("--java-options", "-Djava.rmi.server.hostname=localhost"); cliCreateServer.createServer(); } { - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setUser("admin").setPassword("admin").setAllowAnonymous(true).setNoWeb(true).setArtemisInstance(server1Location).setConfiguration("./src/main/resources/servers/replicated-failback-primary2").setArgs("--java-options", "-Djava.rmi.server.hostname=localhost"); cliCreateServer.createServer(); } { - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setUser("admin").setPassword("admin").setAllowAnonymous(true).setNoWeb(true).setArtemisInstance(server2Location).setConfiguration("./src/main/resources/servers/replicated-failback-primary3").setArgs("--java-options", "-Djava.rmi.server.hostname=localhost"); cliCreateServer.createServer(); } { - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setUser("admin").setPassword("admin").setAllowAnonymous(true).setNoWeb(true).setArtemisInstance(server3Location).setConfiguration("./src/main/resources/servers/replicated-failback-backup1").setArgs("--java-options", "-Djava.rmi.server.hostname=localhost"); cliCreateServer.createServer(); } diff --git a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/jmxrbac/JmxRBACBrokerSecurityTest.java b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/jmxrbac/JmxRBACBrokerSecurityTest.java index 5198bd61063..69c441f06a9 100644 --- a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/jmxrbac/JmxRBACBrokerSecurityTest.java +++ b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/jmxrbac/JmxRBACBrokerSecurityTest.java @@ -37,7 +37,7 @@ import org.apache.activemq.artemis.api.core.management.ObjectNameBuilder; import org.apache.activemq.artemis.tests.smoke.common.SmokeTestBase; import org.apache.activemq.artemis.util.ServerUtil; -import org.apache.activemq.artemis.utils.cli.helper.HelperCreate; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.junit.jupiter.api.BeforeAll; import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.Test; @@ -65,7 +65,7 @@ public static void createServers() throws Exception { deleteDirectory(server0Location); { - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setRole("amq").setUser("admin").setPassword("admin").setAllowAnonymous(false).setNoWeb(false).setArtemisInstance(server0Location). setConfiguration("./src/main/resources/servers/jmx-rbac-broker-security").setArgs("--java-options", "-Djava.rmi.server.hostname=localhost -Djavax.management.builder.initial=org.apache.activemq.artemis.core.server.management.ArtemisRbacMBeanServerBuilder"); cliCreateServer.createServer(); diff --git a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/jmxrbac/JmxRBACTest.java b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/jmxrbac/JmxRBACTest.java index 7e6d51da451..325ee06566a 100644 --- a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/jmxrbac/JmxRBACTest.java +++ b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/jmxrbac/JmxRBACTest.java @@ -38,7 +38,7 @@ import org.apache.activemq.artemis.api.core.management.ObjectNameBuilder; import org.apache.activemq.artemis.tests.smoke.common.SmokeTestBase; import org.apache.activemq.artemis.util.ServerUtil; -import org.apache.activemq.artemis.utils.cli.helper.HelperCreate; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.junit.jupiter.api.BeforeAll; import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.Test; @@ -65,7 +65,7 @@ public static void createServers() throws Exception { deleteDirectory(server0Location); { - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setRole("amq").setUser("admin").setPassword("admin").setAllowAnonymous(false).setNoWeb(true).setArtemisInstance(server0Location). setConfiguration("./src/main/resources/servers/jmx-rbac").setArgs("--java-options", "-Djava.rmi.server.hostname=localhost"); cliCreateServer.createServer(); diff --git a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/lockmanager/LockManagerSinglePairTest.java b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/lockmanager/LockManagerSinglePairTest.java index d95c3c50edb..97233ca96e1 100644 --- a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/lockmanager/LockManagerSinglePairTest.java +++ b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/lockmanager/LockManagerSinglePairTest.java @@ -34,7 +34,7 @@ import org.apache.activemq.artemis.tests.util.Jmx; import org.apache.activemq.artemis.util.ServerUtil; import org.apache.activemq.artemis.utils.Wait; -import org.apache.activemq.artemis.utils.cli.helper.HelperCreate; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.junit.jupiter.api.AfterEach; import org.junit.jupiter.api.BeforeAll; import org.junit.jupiter.api.BeforeEach; @@ -79,7 +79,7 @@ public static void simpleCreate(String serverName) throws Exception { deleteDirectory(server0Location); { - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setUser("admin").setPassword("admin").setAllowAnonymous(true).setNoWeb(true).setArtemisInstance(server0Location). setConfiguration("./src/main/resources/servers/" + serverName); cliCreateServer.setArgs("--java-options", "-Djava.rmi.server.hostname=localhost"); diff --git a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/logging/AuditLoggerTestBase.java b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/logging/AuditLoggerTestBase.java index 3a219fe6bca..82cd901915c 100644 --- a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/logging/AuditLoggerTestBase.java +++ b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/logging/AuditLoggerTestBase.java @@ -21,7 +21,7 @@ import java.io.PrintWriter; import org.apache.activemq.artemis.tests.smoke.common.SmokeTestBase; -import org.apache.activemq.artemis.utils.cli.helper.HelperCreate; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.junit.jupiter.api.BeforeEach; public abstract class AuditLoggerTestBase extends SmokeTestBase { @@ -35,7 +35,7 @@ public void before() throws Exception { deleteDirectory(server0Location); { - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setUser("admin").setPassword("admin").setAllowAnonymous(true).setNoWeb(true).setArtemisInstance(server0Location). setConfiguration("./src/main/resources/servers/" + getServerName()).setArgs("--java-options", "-Djava.rmi.server.hostname=localhost"); cliCreateServer.createServer(); diff --git a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/maxConsumers/MaxConsumersTest.java b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/maxConsumers/MaxConsumersTest.java index 7eeb44f9f40..83e517264e3 100644 --- a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/maxConsumers/MaxConsumersTest.java +++ b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/maxConsumers/MaxConsumersTest.java @@ -28,7 +28,7 @@ import java.io.File; import org.apache.activemq.artemis.tests.smoke.common.SmokeTestBase; -import org.apache.activemq.artemis.utils.cli.helper.HelperCreate; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.apache.qpid.jms.JmsConnectionFactory; import org.junit.jupiter.api.BeforeAll; import org.junit.jupiter.api.BeforeEach; @@ -64,7 +64,7 @@ public static void createServers() throws Exception { deleteDirectory(server0Location); { - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setUser("admin").setPassword("admin").setAllowAnonymous(true).setNoWeb(true).setArtemisInstance(server0Location). setConfiguration("./src/main/resources/servers/maxConsumers"); cliCreateServer.createServer(); diff --git a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/mqtt/MQTTLeakTest.java b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/mqtt/MQTTLeakTest.java index cb65a2d0f39..3510c707ce5 100644 --- a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/mqtt/MQTTLeakTest.java +++ b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/mqtt/MQTTLeakTest.java @@ -23,7 +23,7 @@ import org.apache.activemq.artemis.tests.smoke.common.SmokeTestBase; import org.apache.activemq.artemis.util.ServerUtil; -import org.apache.activemq.artemis.utils.cli.helper.HelperCreate; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken; import org.eclipse.paho.client.mqttv3.MqttAsyncClient; import org.eclipse.paho.client.mqttv3.MqttCallback; @@ -69,7 +69,7 @@ public static void createServers() throws Exception { deleteDirectory(server0Location); { - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setUser("admin").setPassword("admin").setAllowAnonymous(true).setNoWeb(true).setArtemisInstance(server0Location); //setConfiguration("./src/main/resources/servers/mqtt"); cliCreateServer.createServer(); diff --git a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/nettynative/NettyNativeTest.java b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/nettynative/NettyNativeTest.java index da0e7086bd5..849370b4a0f 100644 --- a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/nettynative/NettyNativeTest.java +++ b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/nettynative/NettyNativeTest.java @@ -24,7 +24,7 @@ import org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory; import org.apache.activemq.artemis.tests.smoke.common.SmokeTestBase; import org.apache.activemq.artemis.util.ServerUtil; -import org.apache.activemq.artemis.utils.cli.helper.HelperCreate; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.junit.jupiter.api.BeforeAll; import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.Test; @@ -52,7 +52,7 @@ public static void createServers() throws Exception { deleteDirectory(server0Location); { - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setRole("amq").setUser("admin").setPassword("admin").setAllowAnonymous(false).setNoWeb(true).setArtemisInstance(server0Location). setConfiguration("./src/main/resources/servers/nettynative"); cliCreateServer.createServer(); diff --git a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/paging/FloodServerWithAsyncSendTest.java b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/paging/FloodServerWithAsyncSendTest.java index c5f6aa9f67d..704d4b699df 100644 --- a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/paging/FloodServerWithAsyncSendTest.java +++ b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/paging/FloodServerWithAsyncSendTest.java @@ -38,7 +38,7 @@ import org.apache.activemq.artemis.tests.smoke.common.SmokeTestBase; import org.apache.activemq.artemis.tests.util.CFUtil; import org.apache.activemq.artemis.utils.RandomUtil; -import org.apache.activemq.artemis.utils.cli.helper.HelperCreate; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.junit.jupiter.api.BeforeAll; import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.Test; @@ -59,7 +59,7 @@ public static void createServers() throws Exception { deleteDirectory(server0Location); { - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setUser("admin").setPassword("admin").setAllowAnonymous(true).setNoWeb(true).setArtemisInstance(server0Location). setConfiguration("./src/main/resources/servers/paging"); cliCreateServer.createServer(); diff --git a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/paging/SmokeMaxMessagePagingTest.java b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/paging/SmokeMaxMessagePagingTest.java index 17f2785b2ac..c513ea76756 100644 --- a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/paging/SmokeMaxMessagePagingTest.java +++ b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/paging/SmokeMaxMessagePagingTest.java @@ -25,7 +25,7 @@ import org.apache.activemq.artemis.cli.commands.ActionContext; import org.apache.activemq.artemis.cli.commands.messages.Producer; import org.apache.activemq.artemis.tests.smoke.common.SmokeTestBase; -import org.apache.activemq.artemis.utils.cli.helper.HelperCreate; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.junit.jupiter.api.BeforeAll; import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.Test; @@ -45,14 +45,14 @@ public static void createServers() throws Exception { deleteDirectory(server1Location); { - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setUser("admin").setPassword("admin").setAllowAnonymous(true).setNoWeb(true).setArtemisInstance(server0Location); cliCreateServer.setArgs("--java-options", "-Djava.rmi.server.hostname=localhost", "--global-max-messages", "1000"); cliCreateServer.createServer(); } { - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setUser("admin").setPassword("admin").setAllowAnonymous(true).setNoWeb(true).setArtemisInstance(server1Location). setConfiguration("./src/main/resources/servers/" + SERVER_NAME_ADDRESS); cliCreateServer.createServer(); diff --git a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/paging/SmokePagingTest.java b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/paging/SmokePagingTest.java index 4a33ed4ed7f..18d04faec03 100644 --- a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/paging/SmokePagingTest.java +++ b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/paging/SmokePagingTest.java @@ -25,7 +25,7 @@ import org.apache.activemq.artemis.cli.commands.messages.Consumer; import org.apache.activemq.artemis.cli.commands.messages.Producer; import org.apache.activemq.artemis.tests.smoke.common.SmokeTestBase; -import org.apache.activemq.artemis.utils.cli.helper.HelperCreate; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.junit.jupiter.api.BeforeAll; import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.Test; @@ -41,7 +41,7 @@ public static void createServers() throws Exception { deleteDirectory(server0Location); { - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setUser("admin").setPassword("admin").setAllowAnonymous(true).setNoWeb(true).setArtemisInstance(server0Location). setConfiguration("./src/main/resources/servers/paging"); cliCreateServer.createServer(); diff --git a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/resourcetest/MaxQueueResourceTest.java b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/resourcetest/MaxQueueResourceTest.java index 22ecf0b885b..2acc90f9526 100644 --- a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/resourcetest/MaxQueueResourceTest.java +++ b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/resourcetest/MaxQueueResourceTest.java @@ -33,7 +33,7 @@ import org.apache.activemq.artemis.tests.smoke.common.SmokeTestBase; import org.apache.activemq.artemis.tests.util.CFUtil; import org.apache.activemq.artemis.util.ServerUtil; -import org.apache.activemq.artemis.utils.cli.helper.HelperCreate; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.junit.jupiter.api.BeforeAll; import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.Test; @@ -49,7 +49,7 @@ public static void createServers() throws Exception { deleteDirectory(server0Location); { - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setUser("A").setPassword("A").setAllowAnonymous(false).setNoWeb(true).setArtemisInstance(server0Location).setConfiguration("./src/main/resources/servers/MaxQueueResourceTest"); cliCreateServer.createServer(); } diff --git a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/retention/ReplayTest.java b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/retention/ReplayTest.java index c6f651d7c88..5c57cdb67e5 100644 --- a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/retention/ReplayTest.java +++ b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/retention/ReplayTest.java @@ -38,7 +38,7 @@ import org.apache.activemq.artemis.tests.smoke.common.SmokeTestBase; import org.apache.activemq.artemis.tests.util.CFUtil; import org.apache.activemq.artemis.utils.RandomUtil; -import org.apache.activemq.artemis.utils.cli.helper.HelperCreate; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.junit.jupiter.api.BeforeAll; import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.Test; @@ -58,7 +58,7 @@ public static void createServers() throws Exception { deleteDirectory(server0Location); { - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setRole("amq").setUser("admin").setPassword("admin").setAllowAnonymous(true).setNoWeb(true).setArtemisInstance(server0Location). setConfiguration("./src/main/resources/servers/replay/replay"); cliCreateServer.setArgs("--java-options", "-Djava.rmi.server.hostname=localhost", "--journal-retention", "1", "--queues", "RetentionTest", "--name", "replay"); diff --git a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/topologycheck/TopologyCheckTest.java b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/topologycheck/TopologyCheckTest.java index 10a2c49f786..8107f229919 100644 --- a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/topologycheck/TopologyCheckTest.java +++ b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/topologycheck/TopologyCheckTest.java @@ -33,7 +33,7 @@ import org.apache.activemq.artemis.tests.smoke.common.SmokeTestBase; import org.apache.activemq.artemis.util.ServerUtil; import org.apache.activemq.artemis.utils.Wait; -import org.apache.activemq.artemis.utils.cli.helper.HelperCreate; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.junit.jupiter.api.BeforeAll; import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.Test; @@ -140,7 +140,7 @@ public static void createServers() throws Exception { deleteDirectory(server0Location); { - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setUser("admin").setPassword("admin").setAllowAnonymous(true).setNoWeb(true).setArtemisInstance(server0Location). setConfiguration("./src/main/resources/servers/" + serverConfigName); cliCreateServer.createServer(); diff --git a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/transfer/TransferTest.java b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/transfer/TransferTest.java index 074902522c0..ddb33dc7ae1 100644 --- a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/transfer/TransferTest.java +++ b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/transfer/TransferTest.java @@ -38,7 +38,7 @@ import org.apache.activemq.artemis.tests.smoke.common.SmokeTestBase; import org.apache.activemq.artemis.tests.util.CFUtil; import org.apache.activemq.artemis.util.ServerUtil; -import org.apache.activemq.artemis.utils.cli.helper.HelperCreate; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.junit.jupiter.api.BeforeAll; import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.TestTemplate; @@ -102,13 +102,13 @@ public static void createServers() throws Exception { deleteDirectory(server1Location); { - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setUser("admin").setPassword("admin").setAllowAnonymous(true).setNoWeb(true).setArtemisInstance(server0Location); cliCreateServer.createServer(); } { - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setUser("admin").setPassword("admin").setAllowAnonymous(true).setNoWeb(true).setArtemisInstance(server1Location).setPortOffset(100); cliCreateServer.createServer(); } diff --git a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/AccumulatedInPageSoakTest.java b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/AccumulatedInPageSoakTest.java index 0f133ae98fc..60c0d7e2b6c 100644 --- a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/AccumulatedInPageSoakTest.java +++ b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/AccumulatedInPageSoakTest.java @@ -40,7 +40,7 @@ import org.apache.activemq.artemis.tests.util.RandomUtil; import org.apache.activemq.artemis.util.ServerUtil; import org.apache.activemq.artemis.utils.Wait; -import org.apache.activemq.artemis.utils.cli.helper.HelperCreate; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.junit.jupiter.api.BeforeAll; import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.Test; @@ -86,7 +86,7 @@ private static void createServer(String serverName, File serverLocation = getFileServerLocation(serverName); deleteDirectory(serverLocation); - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setAllowAnonymous(true).setNoWeb(true).setArtemisInstance(serverLocation); cliCreateServer.setMessageLoadBalancing("ON_DEMAND"); cliCreateServer.setClustered(false); diff --git a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/ClusteredMirrorSoakTest.java b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/ClusteredMirrorSoakTest.java index 9f605a3f2d1..8269d78872a 100644 --- a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/ClusteredMirrorSoakTest.java +++ b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/ClusteredMirrorSoakTest.java @@ -58,7 +58,7 @@ import org.apache.activemq.artemis.util.ServerUtil; import org.apache.activemq.artemis.utils.FileUtil; import org.apache.activemq.artemis.utils.Wait; -import org.apache.activemq.artemis.utils.cli.helper.HelperCreate; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.junit.jupiter.api.Test; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -97,7 +97,7 @@ private static void createServer(String serverName, String connectionName, Strin File serverLocation = getFileServerLocation(serverName); deleteDirectory(serverLocation); - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setAllowAnonymous(true).setArtemisInstance(serverLocation); cliCreateServer.setMessageLoadBalancing("ON_DEMAND"); cliCreateServer.setClustered(true); diff --git a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/DivertSoakMirrorTest.java b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/DivertSoakMirrorTest.java index e9a6f18569b..08dbeab4897 100644 --- a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/DivertSoakMirrorTest.java +++ b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/DivertSoakMirrorTest.java @@ -39,7 +39,7 @@ import org.apache.activemq.artemis.utils.FileUtil; import org.apache.activemq.artemis.utils.TestParameters; import org.apache.activemq.artemis.utils.Wait; -import org.apache.activemq.artemis.utils.cli.helper.HelperCreate; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.junit.jupiter.api.AfterEach; import org.junit.jupiter.api.Test; import org.slf4j.Logger; @@ -122,7 +122,7 @@ private static void createMirroredServer(boolean paging, } deleteDirectory(serverLocation); - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setAllowAnonymous(true).setArtemisInstance(serverLocation); cliCreateServer.setArgs("--no-stomp-acceptor", "--no-hornetq-acceptor", "--no-mqtt-acceptor", "--no-amqp-acceptor", "--max-hops", "1", "--name", DC1_NODE); cliCreateServer.addArgs("--queues", QUEUE_NAME_LIST); diff --git a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/IdempotentACKTest.java b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/IdempotentACKTest.java index b9e5200d8b9..43d4ccdd7dd 100644 --- a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/IdempotentACKTest.java +++ b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/IdempotentACKTest.java @@ -46,7 +46,7 @@ import org.apache.activemq.artemis.tests.util.CFUtil; import org.apache.activemq.artemis.util.ServerUtil; import org.apache.activemq.artemis.utils.Wait; -import org.apache.activemq.artemis.utils.cli.helper.HelperCreate; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.junit.jupiter.api.BeforeAll; import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.Test; @@ -85,7 +85,7 @@ private static void createServer(String serverName, File serverLocation = getFileServerLocation(serverName); deleteDirectory(serverLocation); - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setAllowAnonymous(true).setNoWeb(true).setArtemisInstance(serverLocation); cliCreateServer.setMessageLoadBalancing("ON_DEMAND"); cliCreateServer.setClustered(false); diff --git a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/InterruptedLargeMessageTest.java b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/InterruptedLargeMessageTest.java index 69b078b5be9..9b1b4d38066 100644 --- a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/InterruptedLargeMessageTest.java +++ b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/InterruptedLargeMessageTest.java @@ -47,7 +47,7 @@ import org.apache.activemq.artemis.util.ServerUtil; import org.apache.activemq.artemis.utils.FileUtil; import org.apache.activemq.artemis.utils.Wait; -import org.apache.activemq.artemis.utils.cli.helper.HelperCreate; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.junit.jupiter.api.BeforeAll; import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.Test; @@ -89,7 +89,7 @@ private static void createServer(String serverName, File serverLocation = getFileServerLocation(serverName); deleteDirectory(serverLocation); - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setAllowAnonymous(true).setNoWeb(true).setArtemisInstance(serverLocation); cliCreateServer.setMessageLoadBalancing("ON_DEMAND"); cliCreateServer.setClustered(false); diff --git a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/MultiMirrorSoakTest.java b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/MultiMirrorSoakTest.java index 521cc92210c..fc2ad18709f 100644 --- a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/MultiMirrorSoakTest.java +++ b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/MultiMirrorSoakTest.java @@ -41,7 +41,7 @@ import org.apache.activemq.artemis.util.ServerUtil; import org.apache.activemq.artemis.utils.FileUtil; import org.apache.activemq.artemis.utils.Wait; -import org.apache.activemq.artemis.utils.cli.helper.HelperCreate; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.junit.jupiter.api.Test; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -80,7 +80,7 @@ private static void createServer(String serverName, File serverLocation = getFileServerLocation(serverName); deleteDirectory(serverLocation); - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setAllowAnonymous(true).setArtemisInstance(serverLocation); cliCreateServer.setMessageLoadBalancing("ON_DEMAND"); cliCreateServer.setClustered(false); diff --git a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/PagedSNFSoakTest.java b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/PagedSNFSoakTest.java index cf6347edb82..1226a81d29b 100644 --- a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/PagedSNFSoakTest.java +++ b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/PagedSNFSoakTest.java @@ -42,7 +42,7 @@ import org.apache.activemq.artemis.tests.util.CFUtil; import org.apache.activemq.artemis.util.ServerUtil; import org.apache.activemq.artemis.utils.Wait; -import org.apache.activemq.artemis.utils.cli.helper.HelperCreate; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.junit.jupiter.api.BeforeAll; import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.Test; @@ -84,7 +84,7 @@ private static void createServer(String serverName, File serverLocation = getFileServerLocation(serverName); deleteDirectory(serverLocation); - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setAllowAnonymous(true).setNoWeb(true).setArtemisInstance(serverLocation); cliCreateServer.setMessageLoadBalancing("ON_DEMAND"); cliCreateServer.setClustered(false); diff --git a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/ReplicatedBothNodesMirrorTest.java b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/ReplicatedBothNodesMirrorTest.java index dd0ad73348c..90e3aad0078 100644 --- a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/ReplicatedBothNodesMirrorTest.java +++ b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/ReplicatedBothNodesMirrorTest.java @@ -49,7 +49,7 @@ import org.apache.activemq.artemis.utils.FileUtil; import org.apache.activemq.artemis.utils.TestParameters; import org.apache.activemq.artemis.utils.Wait; -import org.apache.activemq.artemis.utils.cli.helper.HelperCreate; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.junit.jupiter.api.AfterEach; import org.junit.jupiter.api.Assumptions; import org.junit.jupiter.api.Test; @@ -168,7 +168,7 @@ private static void createMirroredServer(boolean paging, String serverName, } deleteDirectory(serverLocation); - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setAllowAnonymous(true).setArtemisInstance(serverLocation); cliCreateServer.setArgs("--no-stomp-acceptor", "--no-hornetq-acceptor", "--no-mqtt-acceptor", "--no-amqp-acceptor", "--max-hops", "1", "--name", DC1_NODE); cliCreateServer.addArgs("--queues", QUEUE_NAME); @@ -235,7 +235,7 @@ private static void createMirroredBackupServer(boolean paging, String serverName } deleteDirectory(serverLocation); - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setAllowAnonymous(true).setArtemisInstance(serverLocation); cliCreateServer.setMessageLoadBalancing("ON_DEMAND"); cliCreateServer.setArgs("--no-stomp-acceptor", "--no-hornetq-acceptor", "--no-mqtt-acceptor", "--no-amqp-acceptor", "--max-hops", "1", "--name", DC1_NODE); diff --git a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/ReplicatedMirrorTargetTest.java b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/ReplicatedMirrorTargetTest.java index 05a26d2aa9e..65b8f59e4db 100644 --- a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/ReplicatedMirrorTargetTest.java +++ b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/ReplicatedMirrorTargetTest.java @@ -52,7 +52,7 @@ import org.apache.activemq.artemis.utils.TestParameters; import org.apache.activemq.artemis.utils.Wait; import org.apache.activemq.artemis.utils.actors.OrderedExecutor; -import org.apache.activemq.artemis.utils.cli.helper.HelperCreate; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.junit.jupiter.api.AfterEach; import org.junit.jupiter.api.Test; import org.slf4j.Logger; @@ -140,7 +140,7 @@ private static void createServer(String serverName, File serverLocation = getFileServerLocation(serverName); deleteDirectory(serverLocation); - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setAllowAnonymous(true).setArtemisInstance(serverLocation); cliCreateServer.setNoWeb(false); cliCreateServer.setArgs("--no-stomp-acceptor", "--no-hornetq-acceptor", "--no-mqtt-acceptor", "--no-amqp-acceptor", "--max-hops", "1", "--name", DC1_NODE); @@ -200,7 +200,7 @@ private static void createBackupServer(String serverName, File serverLocation = getFileServerLocation(serverName); deleteDirectory(serverLocation); - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setAllowAnonymous(true).setArtemisInstance(serverLocation); cliCreateServer.setMessageLoadBalancing("ON_DEMAND"); cliCreateServer.setNoWeb(false); diff --git a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/SingleMirrorSoakTest.java b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/SingleMirrorSoakTest.java index 654b3686502..8585d9de040 100644 --- a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/SingleMirrorSoakTest.java +++ b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/SingleMirrorSoakTest.java @@ -53,7 +53,7 @@ import org.apache.activemq.artemis.utils.TestParameters; import org.apache.activemq.artemis.utils.Wait; import org.apache.activemq.artemis.utils.actors.OrderedExecutor; -import org.apache.activemq.artemis.utils.cli.helper.HelperCreate; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.junit.jupiter.api.AfterEach; import org.junit.jupiter.api.Test; import org.slf4j.Logger; @@ -129,7 +129,7 @@ private static void createServer(String serverName, File serverLocation = getFileServerLocation(serverName); deleteDirectory(serverLocation); - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setAllowAnonymous(true).setArtemisInstance(serverLocation); cliCreateServer.setMessageLoadBalancing("ON_DEMAND"); cliCreateServer.setClustered(false); diff --git a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/sender/SenderSoakTest.java b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/sender/SenderSoakTest.java index 805067d4892..f56fcb7f9b1 100644 --- a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/sender/SenderSoakTest.java +++ b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/sender/SenderSoakTest.java @@ -35,7 +35,7 @@ import org.apache.activemq.artemis.tests.soak.SoakTestBase; import org.apache.activemq.artemis.tests.util.CFUtil; import org.apache.activemq.artemis.util.ServerUtil; -import org.apache.activemq.artemis.utils.cli.helper.HelperCreate; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.junit.jupiter.api.Test; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -68,7 +68,7 @@ private static void createServer(String serverName, int portOffset) throws Excep File serverLocation = getFileServerLocation(serverName); deleteDirectory(serverLocation); - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setAllowAnonymous(true).setNoWeb(true).setArtemisInstance(serverLocation); cliCreateServer.setMessageLoadBalancing("STRICT"); cliCreateServer.setClustered(false); diff --git a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/clientFailure/ClientFailureSoakTest.java b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/clientFailure/ClientFailureSoakTest.java index 3884608e909..c7c0656c567 100644 --- a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/clientFailure/ClientFailureSoakTest.java +++ b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/clientFailure/ClientFailureSoakTest.java @@ -48,13 +48,13 @@ import org.apache.activemq.ActiveMQConnectionFactory; import org.apache.activemq.RedeliveryPolicy; import org.apache.activemq.artemis.api.core.management.SimpleManagement; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.apache.activemq.artemis.tests.extensions.parameterized.ParameterizedTestExtension; import org.apache.activemq.artemis.tests.extensions.parameterized.Parameters; import org.apache.activemq.artemis.tests.soak.SoakTestBase; import org.apache.activemq.artemis.tests.util.CFUtil; import org.apache.activemq.artemis.utils.SpawnedVMSupport; import org.apache.activemq.artemis.utils.Wait; -import org.apache.activemq.artemis.utils.cli.helper.HelperCreate; import org.junit.jupiter.api.BeforeAll; import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.TestTemplate; @@ -77,7 +77,7 @@ public class ClientFailureSoakTest extends SoakTestBase { public static void createServers() throws Exception { File serverLocation = getFileServerLocation(SERVER_NAME_0); deleteDirectory(serverLocation); - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setAllowAnonymous(true).setArtemisInstance(serverLocation); cliCreateServer.setArgs("--global-max-messages", "500000", "--java-options", "-ea", "--java-options", "-Xmx512M", "--queues", "CLIENT_TEST,OUT_QUEUE"); cliCreateServer.createServer(); diff --git a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/clusterNotificationsContinuity/ClusterNotificationsContinuityTest.java b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/clusterNotificationsContinuity/ClusterNotificationsContinuityTest.java index 9f183dbecb2..f73274faf5f 100644 --- a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/clusterNotificationsContinuity/ClusterNotificationsContinuityTest.java +++ b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/clusterNotificationsContinuity/ClusterNotificationsContinuityTest.java @@ -36,13 +36,13 @@ import java.util.concurrent.TimeUnit; import org.apache.activemq.artemis.api.core.management.SimpleManagement; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory; import org.apache.activemq.artemis.jms.client.ActiveMQDestination; import org.apache.activemq.artemis.tests.soak.SoakTestBase; import org.apache.activemq.artemis.util.ServerUtil; import org.apache.activemq.artemis.utils.SpawnedVMSupport; import org.apache.activemq.artemis.utils.Wait; -import org.apache.activemq.artemis.utils.cli.helper.HelperCreate; import org.junit.jupiter.api.AfterEach; import org.junit.jupiter.api.BeforeAll; import org.junit.jupiter.api.BeforeEach; @@ -103,7 +103,7 @@ public static void createServers() throws Exception { File serverLocation = getFileServerLocation(serverName); deleteDirectory(serverLocation); - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer .setRole("amq") .setUser("admin") diff --git a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/interrupt/JournalFlushInterruptTest.java b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/interrupt/JournalFlushInterruptTest.java index beb07ff5cac..11d8cb77c1b 100644 --- a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/interrupt/JournalFlushInterruptTest.java +++ b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/interrupt/JournalFlushInterruptTest.java @@ -31,10 +31,10 @@ import org.apache.activemq.artemis.api.core.RoutingType; import org.apache.activemq.artemis.api.core.management.ObjectNameBuilder; import org.apache.activemq.artemis.api.core.management.QueueControl; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.apache.activemq.artemis.tests.soak.SoakTestBase; import org.apache.activemq.artemis.tests.util.CFUtil; import org.apache.activemq.artemis.utils.Wait; -import org.apache.activemq.artemis.utils.cli.helper.HelperCreate; import org.junit.jupiter.api.BeforeAll; import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.Test; @@ -51,7 +51,7 @@ public static void createServers() throws Exception { deleteDirectory(server0Location); { - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setRole("amq").setUser("artemis").setPassword("artemis").setAllowAnonymous(true).setNoWeb(false).setArtemisInstance(server0Location). setConfiguration("./src/main/resources/servers/interruptjf"); cliCreateServer.setArgs("--java-options", "-Djava.rmi.server.hostname=localhost", "--queues", "JournalFlushInterruptTest", "--name", "interruptjf"); diff --git a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/interruptlm/ClusteredLargeMessageInterruptTest.java b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/interruptlm/ClusteredLargeMessageInterruptTest.java index f6ff2a70d18..2c4ed313c44 100644 --- a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/interruptlm/ClusteredLargeMessageInterruptTest.java +++ b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/interruptlm/ClusteredLargeMessageInterruptTest.java @@ -43,7 +43,7 @@ import org.apache.activemq.artemis.tests.soak.SoakTestBase; import org.apache.activemq.artemis.tests.util.CFUtil; import org.apache.activemq.artemis.utils.Wait; -import org.apache.activemq.artemis.utils.cli.helper.HelperCreate; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.junit.jupiter.api.BeforeAll; import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.Test; @@ -62,7 +62,7 @@ public static void createServers() throws Exception { File serverLocation = getFileServerLocation(SERVER_NAME_0); deleteDirectory(serverLocation); - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setRole("amq").setUser("artemis").setPassword("artemis").setAllowAnonymous(true).setNoWeb(false).setArtemisInstance(serverLocation). setConfiguration("./src/main/resources/servers/lmbroker1"); cliCreateServer.setArgs("--java-options", "-Djava.rmi.server.hostname=localhost", "--clustered", "--static-cluster", "tcp://localhost:61716", "--queues", "ClusteredLargeMessageInterruptTest", "--name", "lmbroker1"); @@ -73,7 +73,7 @@ public static void createServers() throws Exception { File serverLocation = getFileServerLocation(SERVER_NAME_1); deleteDirectory(serverLocation); - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setRole("amq").setUser("artemis").setPassword("artemis").setAllowAnonymous(true).setNoWeb(false).setArtemisInstance(serverLocation). setConfiguration("./src/main/resources/servers/lmbroker2").setPortOffset(100); cliCreateServer.setArgs("--java-options", "-Djava.rmi.server.hostname=localhost", "--clustered", "--static-cluster", "tcp://localhost:61616", "--queues", "ClusteredLargeMessageInterruptTest", "--name", "lmbroker2"); diff --git a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/interruptlm/LargeMessageInterruptTest.java b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/interruptlm/LargeMessageInterruptTest.java index 208696068e0..788f4d15f12 100644 --- a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/interruptlm/LargeMessageInterruptTest.java +++ b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/interruptlm/LargeMessageInterruptTest.java @@ -43,7 +43,7 @@ import org.apache.activemq.artemis.tests.soak.SoakTestBase; import org.apache.activemq.artemis.tests.util.CFUtil; import org.apache.activemq.artemis.utils.Wait; -import org.apache.activemq.artemis.utils.cli.helper.HelperCreate; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.junit.jupiter.api.BeforeAll; import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.Test; @@ -62,7 +62,7 @@ public static void createServers() throws Exception { File serverLocation = getFileServerLocation(SERVER_NAME_0); deleteDirectory(serverLocation); - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setRole("amq").setUser("artemis").setPassword("artemis").setAllowAnonymous(true).setNoWeb(false).setArtemisInstance(serverLocation). setConfiguration("./src/main/resources/servers/interruptlm"); cliCreateServer.setArgs("--java-options", "-Djava.rmi.server.hostname=localhost", "--clustered", "--static-cluster", "tcp://localhost:61716", "--queues", "ClusteredLargeMessageInterruptTest", "--name", "lmbroker1"); diff --git a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/mqtt/MQTT5SoakTest.java b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/mqtt/MQTT5SoakTest.java index bd498d8e268..d26969f9a77 100644 --- a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/mqtt/MQTT5SoakTest.java +++ b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/mqtt/MQTT5SoakTest.java @@ -31,7 +31,7 @@ import org.apache.activemq.artemis.core.protocol.mqtt.MQTTUtil; import org.apache.activemq.artemis.tests.soak.SoakTestBase; import org.apache.activemq.artemis.utils.Wait; -import org.apache.activemq.artemis.utils.cli.helper.HelperCreate; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.eclipse.paho.mqttv5.client.IMqttToken; import org.eclipse.paho.mqttv5.client.MqttCallback; import org.eclipse.paho.mqttv5.client.MqttClient; @@ -60,7 +60,7 @@ public static void createServers() throws Exception { File serverLocation = getFileServerLocation(SERVER_NAME_0); deleteDirectory(serverLocation); - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setRole("amq").setUser("artemis").setPassword("artemis").setAllowAnonymous(true).setNoWeb(false).setArtemisInstance(serverLocation); cliCreateServer.setArgs("--addresses", "MQTT_SOAK"); cliCreateServer.createServer(); diff --git a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/owleak/OWLeakTest.java b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/owleak/OWLeakTest.java index c632d301492..112b38f34fb 100644 --- a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/owleak/OWLeakTest.java +++ b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/owleak/OWLeakTest.java @@ -41,13 +41,13 @@ import java.util.concurrent.atomic.AtomicBoolean; import java.util.concurrent.atomic.AtomicInteger; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.apache.activemq.artemis.tests.extensions.parameterized.ParameterizedTestExtension; import org.apache.activemq.artemis.tests.extensions.parameterized.Parameters; import org.apache.activemq.artemis.tests.soak.SoakTestBase; import org.apache.activemq.artemis.tests.util.CFUtil; import org.apache.activemq.artemis.utils.SpawnedVMSupport; import org.apache.activemq.artemis.utils.TestParameters; -import org.apache.activemq.artemis.utils.cli.helper.HelperCreate; import org.junit.jupiter.api.BeforeAll; import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.TestTemplate; @@ -76,7 +76,7 @@ public static void createServers() throws Exception { File serverLocation = getFileServerLocation(SERVER_NAME_0); deleteDirectory(serverLocation); - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setRole("amq").setUser("admin").setPassword("admin").setAllowAnonymous(true).setNoWeb(false).setArtemisInstance(serverLocation); cliCreateServer.createServer(); } diff --git a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/paging/FlowControlPagingTest.java b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/paging/FlowControlPagingTest.java index 3ecc1cd07fa..d1f28da0d8e 100644 --- a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/paging/FlowControlPagingTest.java +++ b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/paging/FlowControlPagingTest.java @@ -41,7 +41,7 @@ import org.apache.activemq.artemis.tests.soak.SoakTestBase; import org.apache.activemq.artemis.tests.util.CFUtil; import org.apache.activemq.artemis.utils.TestParameters; -import org.apache.activemq.artemis.utils.cli.helper.HelperCreate; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.junit.jupiter.api.BeforeAll; import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.TestTemplate; @@ -87,7 +87,7 @@ public static void createServers() throws Exception { File serverLocation = getFileServerLocation(SERVER_NAME_0); deleteDirectory(serverLocation); - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setRole("amq").setUser("admin").setPassword("admin").setAllowAnonymous(true).setNoWeb(false).setArtemisInstance(serverLocation); // some limited memory to make it more likely to fail cliCreateServer.setArgs("--java-memory", "512M"); diff --git a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/paging/HorizontalPagingTest.java b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/paging/HorizontalPagingTest.java index 08f20812cf9..64216b8432a 100644 --- a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/paging/HorizontalPagingTest.java +++ b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/paging/HorizontalPagingTest.java @@ -43,7 +43,7 @@ import org.apache.activemq.artemis.tests.util.CFUtil; import org.apache.activemq.artemis.utils.ReusableLatch; import org.apache.activemq.artemis.utils.TestParameters; -import org.apache.activemq.artemis.utils.cli.helper.HelperCreate; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.junit.jupiter.api.BeforeAll; import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.TestTemplate; @@ -89,7 +89,7 @@ public static void createServers() throws Exception { File serverLocation = getFileServerLocation(SERVER_NAME_0); deleteDirectory(serverLocation); - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setRole("amq").setUser("admin").setPassword("admin").setAllowAnonymous(true).setNoWeb(false).setArtemisInstance(serverLocation); // some limited memory to make it more likely to fail cliCreateServer.setArgs("--java-memory", "2g"); diff --git a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/paging/M_and_M_FactoryTest.java b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/paging/M_and_M_FactoryTest.java index 4610fc1a5cd..f74b2639e39 100644 --- a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/paging/M_and_M_FactoryTest.java +++ b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/paging/M_and_M_FactoryTest.java @@ -46,7 +46,7 @@ import org.apache.activemq.artemis.utils.RandomUtil; import org.apache.activemq.artemis.utils.SpawnedVMSupport; import org.apache.activemq.artemis.utils.Wait; -import org.apache.activemq.artemis.utils.cli.helper.HelperCreate; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.junit.jupiter.api.BeforeAll; import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.Test; @@ -68,7 +68,7 @@ public static void createServers() throws Exception { File serverLocation = getFileServerLocation(SERVER_NAME_0); deleteDirectory(serverLocation); - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setUser("admin").setPassword("admin").setAllowAnonymous(true).setNoWeb(false).setArtemisInstance(serverLocation); cliCreateServer.setConfiguration("./src/main/resources/servers/mmfactory"); cliCreateServer.setArgs("--java-options", "-Djava.rmi.server.hostname=localhost -Dcom.sun.management.jmxremote=true -Dcom.sun.management.jmxremote.port=11099 -Dcom.sun.management.jmxremote.rmi.port=11098 -Dcom.sun.management.jmxremote.ssl=false -Dcom.sun.management.jmxremote.authenticate=false"); diff --git a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/paging/SubscriptionPagingTest.java b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/paging/SubscriptionPagingTest.java index 1247ffcc401..030d060a6d2 100644 --- a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/paging/SubscriptionPagingTest.java +++ b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/paging/SubscriptionPagingTest.java @@ -40,12 +40,12 @@ import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicInteger; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.apache.activemq.artemis.tests.extensions.parameterized.ParameterizedTestExtension; import org.apache.activemq.artemis.tests.extensions.parameterized.Parameters; import org.apache.activemq.artemis.tests.soak.SoakTestBase; import org.apache.activemq.artemis.tests.util.CFUtil; import org.apache.activemq.artemis.utils.TestParameters; -import org.apache.activemq.artemis.utils.cli.helper.HelperCreate; import org.junit.jupiter.api.BeforeAll; import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.TestTemplate; @@ -91,7 +91,7 @@ public static void createServers() throws Exception { File serverLocation = getFileServerLocation(SERVER_NAME_0); deleteDirectory(serverLocation); - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setRole("amq").setUser("admin").setPassword("admin").setAllowAnonymous(true).setNoWeb(false).setArtemisInstance(serverLocation); // some limited memory to make it more likely to fail cliCreateServer.setArgs("--java-memory", "512M"); diff --git a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/paging/ValidateExportSpeedTest.java b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/paging/ValidateExportSpeedTest.java index 2c858126e64..c42d40a49bf 100644 --- a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/paging/ValidateExportSpeedTest.java +++ b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/paging/ValidateExportSpeedTest.java @@ -42,7 +42,7 @@ import org.apache.activemq.artemis.tests.soak.SoakTestBase; import org.apache.activemq.artemis.tests.util.CFUtil; import org.apache.activemq.artemis.utils.Wait; -import org.apache.activemq.artemis.utils.cli.helper.HelperCreate; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.junit.jupiter.api.AfterEach; import org.junit.jupiter.api.BeforeAll; import org.junit.jupiter.api.BeforeEach; @@ -61,7 +61,7 @@ public static void createServers() throws Exception { File serverLocation = getFileServerLocation(SERVER_NAME_0); deleteDirectory(serverLocation); - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setRole("amq").setUser("admin").setPassword("admin").setAllowAnonymous(true).setNoWeb(false).setArtemisInstance(serverLocation); cliCreateServer.setArgs("--global-max-messages", "10000", "--java-options", "-ea", "--queues", "TEST"); cliCreateServer.createServer(); diff --git a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/replicaTxCheck/ReplicaTXCheckTest.java b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/replicaTxCheck/ReplicaTXCheckTest.java index 17393424783..4fb70923913 100644 --- a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/replicaTxCheck/ReplicaTXCheckTest.java +++ b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/replicaTxCheck/ReplicaTXCheckTest.java @@ -34,7 +34,7 @@ import org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory; import org.apache.activemq.artemis.tests.soak.SoakTestBase; import org.apache.activemq.artemis.util.ServerUtil; -import org.apache.activemq.artemis.utils.cli.helper.HelperCreate; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.apache.qpid.jms.JmsConnectionFactory; import org.junit.jupiter.api.AfterEach; import org.junit.jupiter.api.BeforeAll; @@ -58,7 +58,7 @@ private static void createServer(String name) throws Exception { File serverLocation = getFileServerLocation(name); deleteDirectory(serverLocation); - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setAllowAnonymous(true).setNoWeb(true).setArtemisInstance(serverLocation); cliCreateServer.setConfiguration("./src/main/resources/servers/" + name); cliCreateServer.createServer(); diff --git a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/replicationflow/ReplicationFlowControlTest.java b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/replicationflow/ReplicationFlowControlTest.java index a810be3a77f..5bf9626f1ae 100644 --- a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/replicationflow/ReplicationFlowControlTest.java +++ b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/replicationflow/ReplicationFlowControlTest.java @@ -32,11 +32,11 @@ import java.util.concurrent.atomic.AtomicBoolean; import java.util.concurrent.atomic.AtomicInteger; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory; import org.apache.activemq.artemis.tests.soak.SoakTestBase; import org.apache.activemq.artemis.util.ServerUtil; import org.apache.activemq.artemis.utils.ReusableLatch; -import org.apache.activemq.artemis.utils.cli.helper.HelperCreate; import org.apache.qpid.jms.JmsConnectionFactory; import org.junit.jupiter.api.AfterEach; import org.junit.jupiter.api.BeforeAll; @@ -55,7 +55,7 @@ public static void createServers() throws Exception { File serverLocation = getFileServerLocation(SERVER_NAME_0); deleteDirectory(serverLocation); - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setAllowAnonymous(true).setNoWeb(true).setArtemisInstance(serverLocation); cliCreateServer.setConfiguration("./src/main/resources/servers/replicated-static0"); cliCreateServer.createServer(); @@ -64,7 +64,7 @@ public static void createServers() throws Exception { File serverLocation = getFileServerLocation(SERVER_NAME_1); deleteDirectory(serverLocation); - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setAllowAnonymous(true).setNoWeb(true).setArtemisInstance(serverLocation); cliCreateServer.setConfiguration("./src/main/resources/servers/replicated-static1"); cliCreateServer.createServer(); diff --git a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/replicationflow/SoakReplicatedPagingTest.java b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/replicationflow/SoakReplicatedPagingTest.java index 4bc9390d3b6..b0bb6daefac 100644 --- a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/replicationflow/SoakReplicatedPagingTest.java +++ b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/replicationflow/SoakReplicatedPagingTest.java @@ -55,13 +55,13 @@ import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicInteger; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.apache.activemq.artemis.tests.extensions.parameterized.ParameterizedTestExtension; import org.apache.activemq.artemis.tests.extensions.parameterized.Parameters; import org.apache.activemq.artemis.tests.soak.SoakTestBase; import org.apache.activemq.artemis.utils.ExecuteUtil; import org.apache.activemq.artemis.utils.SpawnedVMSupport; import org.apache.activemq.artemis.utils.Wait; -import org.apache.activemq.artemis.utils.cli.helper.HelperCreate; import org.apache.qpid.jms.JmsConnectionFactory; import org.fusesource.mqtt.client.BlockingConnection; import org.fusesource.mqtt.client.MQTT; @@ -122,7 +122,7 @@ public static void createServers() throws Exception { File serverLocation = getFileServerLocation(SERVER_NAME_0); deleteDirectory(serverLocation); - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setAllowAnonymous(true).setNoWeb(true).setArtemisInstance(serverLocation); cliCreateServer.setConfiguration("./src/main/resources/servers/replicated-static0"); cliCreateServer.createServer(); @@ -131,7 +131,7 @@ public static void createServers() throws Exception { File serverLocation = getFileServerLocation(SERVER_NAME_1); deleteDirectory(serverLocation); - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setAllowAnonymous(true).setNoWeb(true).setArtemisInstance(serverLocation); cliCreateServer.setConfiguration("./src/main/resources/servers/replicated-static1"); cliCreateServer.createServer(); diff --git a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/retention/LargeMessageRetentionTest.java b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/retention/LargeMessageRetentionTest.java index 1fbcbe71e20..62300762d64 100644 --- a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/retention/LargeMessageRetentionTest.java +++ b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/retention/LargeMessageRetentionTest.java @@ -45,11 +45,11 @@ import org.apache.activemq.artemis.api.core.management.ActiveMQServerControl; import org.apache.activemq.artemis.api.core.management.ObjectNameBuilder; import org.apache.activemq.artemis.api.core.management.SimpleManagement; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.apache.activemq.artemis.tests.soak.SoakTestBase; import org.apache.activemq.artemis.tests.util.CFUtil; import org.apache.activemq.artemis.utils.RandomUtil; import org.apache.activemq.artemis.utils.Wait; -import org.apache.activemq.artemis.utils.cli.helper.HelperCreate; import org.junit.jupiter.api.BeforeAll; import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.Test; @@ -76,7 +76,7 @@ public static void createServers() throws Exception { File serverLocation = getFileServerLocation(SERVER_NAME_0); deleteDirectory(serverLocation); - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setRole("amq").setUser("artemis").setPassword("artemis").setAllowAnonymous(true).setNoWeb(false); cliCreateServer.setAllowAnonymous(true).setNoWeb(true).setArtemisInstance(serverLocation); cliCreateServer.setConfiguration("./src/main/resources/servers/replay/large-message"); diff --git a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/stomp/StompSoakTest.java b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/stomp/StompSoakTest.java index a392b020a0e..cc9aed29203 100644 --- a/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/stomp/StompSoakTest.java +++ b/tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/stomp/StompSoakTest.java @@ -43,7 +43,7 @@ import org.apache.activemq.artemis.tests.integration.stomp.util.StompClientConnection; import org.apache.activemq.artemis.tests.integration.stomp.util.StompClientConnectionFactory; import org.apache.activemq.artemis.tests.soak.SoakTestBase; -import org.apache.activemq.artemis.utils.cli.helper.HelperCreate; +import org.apache.activemq.artemis.cli.commands.helper.HelperCreate; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -69,7 +69,7 @@ public static void createServer() throws Exception { File serverLocation = getFileServerLocation(SERVER_NAME_0); deleteDirectory(serverLocation); - HelperCreate cliCreateServer = new HelperCreate(); + HelperCreate cliCreateServer = helperCreate(); cliCreateServer.setRole("amq").setUser("admin").setPassword("admin").setAllowAnonymous(true).setNoWeb(false) .setArtemisInstance(serverLocation); // some limited memory to make it more likely to fail