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

NO-JIRA Fixing typo on porOffset -> portOffset

This commit is contained in:
Clebert Suconic 2024-08-20 14:42:56 -04:00 committed by clebertsuconic
parent d41f01a5aa
commit ac666f3ab1
13 changed files with 32 additions and 32 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/brokerConnection/DivertQueueMirrorTest.java
View File

@ -75,7 +75,7 @@ public class DivertQueueMirrorTest extends SmokeTestBase {
private static void createServer(String serverName, private static void createServer(String serverName,
String connectionName, String connectionName,
String mirrorURI, String mirrorURI,
int porOffset) throws Exception { int portOffset) throws Exception {
File serverLocation = getFileServerLocation(serverName); File serverLocation = getFileServerLocation(serverName);
deleteDirectory(serverLocation); deleteDirectory(serverLocation);
@ -87,7 +87,7 @@ public class DivertQueueMirrorTest extends SmokeTestBase {
cliCreateServer.setArgs("--no-stomp-acceptor", "--no-hornetq-acceptor", "--no-mqtt-acceptor", "--no-amqp-acceptor", "--max-hops", "1", "--name", DC1_NODE_A); cliCreateServer.setArgs("--no-stomp-acceptor", "--no-hornetq-acceptor", "--no-mqtt-acceptor", "--no-amqp-acceptor", "--max-hops", "1", "--name", DC1_NODE_A);
cliCreateServer.addArgs("--queues", CREATE_QUEUE); cliCreateServer.addArgs("--queues", CREATE_QUEUE);
cliCreateServer.addArgs("--java-memory", "512M"); cliCreateServer.addArgs("--java-memory", "512M");
cliCreateServer.setPortOffset(porOffset); cliCreateServer.setPortOffset(portOffset);
cliCreateServer.createServer(); cliCreateServer.createServer();
Properties brokerProperties = new Properties(); Properties brokerProperties = new Properties();

8
tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/brokerConnection/MirrorInfiniteRetryReplicaTest.java
View File

@ -97,7 +97,7 @@ public class MirrorInfiniteRetryReplicaTest extends SmokeTestBase {
private static void createMirroredServer(String serverName, private static void createMirroredServer(String serverName,
String connectionName, String connectionName,
String mirrorURI, String mirrorURI,
int porOffset, int portOffset,
boolean replicated, boolean replicated,
String clusterStatic) throws Exception { String clusterStatic) throws Exception {
File serverLocation = getFileServerLocation(serverName); File serverLocation = getFileServerLocation(serverName);
@ -108,7 +108,7 @@ public class MirrorInfiniteRetryReplicaTest extends SmokeTestBase {
cliCreateServer.setNoWeb(true); cliCreateServer.setNoWeb(true);
cliCreateServer.setArgs("--no-stomp-acceptor", "--no-hornetq-acceptor", "--no-mqtt-acceptor", "--no-amqp-acceptor", "--max-hops", "1", "--name", DC1_NODE); 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); cliCreateServer.addArgs("--queues", QUEUE_NAME);
cliCreateServer.setPortOffset(porOffset); cliCreateServer.setPortOffset(portOffset);
if (replicated) { if (replicated) {
cliCreateServer.setReplicated(true); cliCreateServer.setReplicated(true);
cliCreateServer.setStaticCluster(clusterStatic); cliCreateServer.setStaticCluster(clusterStatic);
@ -162,7 +162,7 @@ public class MirrorInfiniteRetryReplicaTest extends SmokeTestBase {
} }
private static void createMirroredBackupServer(String serverName, private static void createMirroredBackupServer(String serverName,
int porOffset, int portOffset,
String clusterStatic, String clusterStatic,
String mirrorURI) throws Exception { String mirrorURI) throws Exception {
File serverLocation = getFileServerLocation(serverName); File serverLocation = getFileServerLocation(serverName);
@ -173,7 +173,7 @@ public class MirrorInfiniteRetryReplicaTest extends SmokeTestBase {
cliCreateServer.setMessageLoadBalancing("ON_DEMAND"); cliCreateServer.setMessageLoadBalancing("ON_DEMAND");
cliCreateServer.setNoWeb(true); cliCreateServer.setNoWeb(true);
cliCreateServer.setArgs("--no-stomp-acceptor", "--no-hornetq-acceptor", "--no-mqtt-acceptor", "--no-amqp-acceptor", "--max-hops", "1", "--name", DC1_NODE); cliCreateServer.setArgs("--no-stomp-acceptor", "--no-hornetq-acceptor", "--no-mqtt-acceptor", "--no-amqp-acceptor", "--max-hops", "1", "--name", DC1_NODE);
cliCreateServer.setPortOffset(porOffset); cliCreateServer.setPortOffset(portOffset);
cliCreateServer.setClustered(true); cliCreateServer.setClustered(true);
cliCreateServer.setReplicated(true); cliCreateServer.setReplicated(true);
cliCreateServer.setBackup(true); cliCreateServer.setBackup(true);

4
tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/AccumulatedInPageSoakTest.java
View File

@ -81,7 +81,7 @@ public class AccumulatedInPageSoakTest extends SoakTestBase {
private static void createServer(String serverName, private static void createServer(String serverName,
String connectionName, String connectionName,
String mirrorURI, String mirrorURI,
int porOffset) throws Exception { int portOffset) throws Exception {
File serverLocation = getFileServerLocation(serverName); File serverLocation = getFileServerLocation(serverName);
deleteDirectory(serverLocation); deleteDirectory(serverLocation);
@ -93,7 +93,7 @@ public class AccumulatedInPageSoakTest extends SoakTestBase {
cliCreateServer.setArgs("--no-stomp-acceptor", "--no-hornetq-acceptor", "--no-mqtt-acceptor", "--no-amqp-acceptor", "--max-hops", "1", "--name", DC1_NODE_A); cliCreateServer.setArgs("--no-stomp-acceptor", "--no-hornetq-acceptor", "--no-mqtt-acceptor", "--no-amqp-acceptor", "--max-hops", "1", "--name", DC1_NODE_A);
cliCreateServer.addArgs("--queues", QUEUE_NAME); cliCreateServer.addArgs("--queues", QUEUE_NAME);
cliCreateServer.addArgs("--java-memory", "512M"); cliCreateServer.addArgs("--java-memory", "512M");
cliCreateServer.setPortOffset(porOffset); cliCreateServer.setPortOffset(portOffset);
cliCreateServer.createServer(); cliCreateServer.createServer();
Properties brokerProperties = new Properties(); Properties brokerProperties = new Properties();

4
tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/ClusteredMirrorSoakTest.java
View File

@ -93,7 +93,7 @@ public class ClusteredMirrorSoakTest extends SoakTestBase {
private static String DC2_NODEA_URI = "tcp://localhost:61618"; private static String DC2_NODEA_URI = "tcp://localhost:61618";
private static String DC2_NODEB_URI = "tcp://localhost:61619"; private static String DC2_NODEB_URI = "tcp://localhost:61619";
private static void createServer(String serverName, String connectionName, String clusterURI, String mirrorURI, int porOffset, boolean paging) throws Exception { private static void createServer(String serverName, String connectionName, String clusterURI, String mirrorURI, int portOffset, boolean paging) throws Exception {
File serverLocation = getFileServerLocation(serverName); File serverLocation = getFileServerLocation(serverName);
deleteDirectory(serverLocation); deleteDirectory(serverLocation);
@ -106,7 +106,7 @@ public class ClusteredMirrorSoakTest extends SoakTestBase {
cliCreateServer.setArgs("--no-stomp-acceptor", "--no-hornetq-acceptor", "--no-mqtt-acceptor", "--no-amqp-acceptor", "--max-hops", "1", "--name", DC1_NODE_A); cliCreateServer.setArgs("--no-stomp-acceptor", "--no-hornetq-acceptor", "--no-mqtt-acceptor", "--no-amqp-acceptor", "--max-hops", "1", "--name", DC1_NODE_A);
cliCreateServer.addArgs("--addresses", "order"); cliCreateServer.addArgs("--addresses", "order");
cliCreateServer.addArgs("--queues", "myQueue"); cliCreateServer.addArgs("--queues", "myQueue");
cliCreateServer.setPortOffset(porOffset); cliCreateServer.setPortOffset(portOffset);
cliCreateServer.createServer(); cliCreateServer.createServer();
Properties brokerProperties = new Properties(); Properties brokerProperties = new Properties();

4
tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/IdempotentACKTest.java
View File

@ -81,7 +81,7 @@ public class IdempotentACKTest extends SoakTestBase {
private static void createServer(String serverName, private static void createServer(String serverName,
String connectionName, String connectionName,
String mirrorURI, String mirrorURI,
int porOffset) throws Exception { int portOffset) throws Exception {
File serverLocation = getFileServerLocation(serverName); File serverLocation = getFileServerLocation(serverName);
deleteDirectory(serverLocation); deleteDirectory(serverLocation);
@ -92,7 +92,7 @@ public class IdempotentACKTest extends SoakTestBase {
cliCreateServer.setNoWeb(true); cliCreateServer.setNoWeb(true);
cliCreateServer.setArgs("--no-stomp-acceptor", "--no-hornetq-acceptor", "--no-mqtt-acceptor", "--no-amqp-acceptor", "--max-hops", "1", "--name", DC1_NODE_A); cliCreateServer.setArgs("--no-stomp-acceptor", "--no-hornetq-acceptor", "--no-mqtt-acceptor", "--no-amqp-acceptor", "--max-hops", "1", "--name", DC1_NODE_A);
cliCreateServer.addArgs("--queues", QUEUE_NAME); cliCreateServer.addArgs("--queues", QUEUE_NAME);
cliCreateServer.setPortOffset(porOffset); cliCreateServer.setPortOffset(portOffset);
cliCreateServer.createServer(); cliCreateServer.createServer();
Properties brokerProperties = new Properties(); Properties brokerProperties = new Properties();

4
tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/InterruptedLargeMessageTest.java
View File

@ -85,7 +85,7 @@ public class InterruptedLargeMessageTest extends SoakTestBase {
private static void createServer(String serverName, private static void createServer(String serverName,
String connectionName, String connectionName,
String mirrorURI, String mirrorURI,
int porOffset) throws Exception { int portOffset) throws Exception {
File serverLocation = getFileServerLocation(serverName); File serverLocation = getFileServerLocation(serverName);
deleteDirectory(serverLocation); deleteDirectory(serverLocation);
@ -96,7 +96,7 @@ public class InterruptedLargeMessageTest extends SoakTestBase {
cliCreateServer.setNoWeb(true); cliCreateServer.setNoWeb(true);
cliCreateServer.setArgs("--no-stomp-acceptor", "--no-hornetq-acceptor", "--no-mqtt-acceptor", "--no-amqp-acceptor", "--max-hops", "1", "--name", DC1_NODE_A); cliCreateServer.setArgs("--no-stomp-acceptor", "--no-hornetq-acceptor", "--no-mqtt-acceptor", "--no-amqp-acceptor", "--max-hops", "1", "--name", DC1_NODE_A);
cliCreateServer.addArgs("--queues", QUEUE_NAME); cliCreateServer.addArgs("--queues", QUEUE_NAME);
cliCreateServer.setPortOffset(porOffset); cliCreateServer.setPortOffset(portOffset);
cliCreateServer.createServer(); cliCreateServer.createServer();
Properties brokerProperties = new Properties(); Properties brokerProperties = new Properties();

4
tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/MultiMirrorSoakTest.java
View File

@ -74,7 +74,7 @@ public class MultiMirrorSoakTest extends SoakTestBase {
private static String DC3_NODEA_URI = "tcp://localhost:61618"; private static String DC3_NODEA_URI = "tcp://localhost:61618";
private static void createServer(String serverName, private static void createServer(String serverName,
int porOffset, int portOffset,
boolean paging, boolean paging,
String... mirrorTo) throws Exception { String... mirrorTo) throws Exception {
File serverLocation = getFileServerLocation(serverName); File serverLocation = getFileServerLocation(serverName);
@ -88,7 +88,7 @@ public class MultiMirrorSoakTest extends SoakTestBase {
cliCreateServer.setArgs("--no-stomp-acceptor", "--no-hornetq-acceptor", "--no-mqtt-acceptor", "--no-amqp-acceptor", "--max-hops", "1", "--name", DC1_NODE_A); cliCreateServer.setArgs("--no-stomp-acceptor", "--no-hornetq-acceptor", "--no-mqtt-acceptor", "--no-amqp-acceptor", "--max-hops", "1", "--name", DC1_NODE_A);
cliCreateServer.addArgs("--addresses", "order"); cliCreateServer.addArgs("--addresses", "order");
cliCreateServer.addArgs("--queues", "myQueue"); cliCreateServer.addArgs("--queues", "myQueue");
cliCreateServer.setPortOffset(porOffset); cliCreateServer.setPortOffset(portOffset);
cliCreateServer.createServer(); cliCreateServer.createServer();
Properties brokerProperties = new Properties(); Properties brokerProperties = new Properties();

4
tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/PagedSNFSoakTest.java
View File

@ -80,7 +80,7 @@ public class PagedSNFSoakTest extends SoakTestBase {
private static void createServer(String serverName, private static void createServer(String serverName,
String connectionName, String connectionName,
String mirrorURI, String mirrorURI,
int porOffset) throws Exception { int portOffset) throws Exception {
File serverLocation = getFileServerLocation(serverName); File serverLocation = getFileServerLocation(serverName);
deleteDirectory(serverLocation); deleteDirectory(serverLocation);
@ -92,7 +92,7 @@ public class PagedSNFSoakTest extends SoakTestBase {
cliCreateServer.setArgs("--no-stomp-acceptor", "--no-hornetq-acceptor", "--no-mqtt-acceptor", "--no-amqp-acceptor", "--max-hops", "1", "--name", DC1_NODE_A); cliCreateServer.setArgs("--no-stomp-acceptor", "--no-hornetq-acceptor", "--no-mqtt-acceptor", "--no-amqp-acceptor", "--max-hops", "1", "--name", DC1_NODE_A);
cliCreateServer.addArgs("--queues", QUEUE_NAME); cliCreateServer.addArgs("--queues", QUEUE_NAME);
cliCreateServer.addArgs("--java-memory", "512M"); cliCreateServer.addArgs("--java-memory", "512M");
cliCreateServer.setPortOffset(porOffset); cliCreateServer.setPortOffset(portOffset);
cliCreateServer.createServer(); cliCreateServer.createServer();
Properties brokerProperties = new Properties(); Properties brokerProperties = new Properties();

4
tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/QuickAckMirrorTest.java
View File

@ -62,7 +62,7 @@ public class QuickAckMirrorTest extends SoakTestBase {
private static void createServer(String serverName, private static void createServer(String serverName,
String connectionName, String connectionName,
String mirrorURI, String mirrorURI,
int porOffset) throws Exception { int portOffset) throws Exception {
File serverLocation = getFileServerLocation(serverName); File serverLocation = getFileServerLocation(serverName);
deleteDirectory(serverLocation); deleteDirectory(serverLocation);
@ -73,7 +73,7 @@ public class QuickAckMirrorTest extends SoakTestBase {
cliCreateServer.setNoWeb(true); cliCreateServer.setNoWeb(true);
cliCreateServer.setArgs("--no-stomp-acceptor", "--no-hornetq-acceptor", "--no-mqtt-acceptor", "--no-amqp-acceptor", "--max-hops", "1", "--name", DC1_NODE_A); cliCreateServer.setArgs("--no-stomp-acceptor", "--no-hornetq-acceptor", "--no-mqtt-acceptor", "--no-amqp-acceptor", "--max-hops", "1", "--name", DC1_NODE_A);
cliCreateServer.addArgs("--queues", QUEUE_NAME); cliCreateServer.addArgs("--queues", QUEUE_NAME);
cliCreateServer.setPortOffset(porOffset); cliCreateServer.setPortOffset(portOffset);
cliCreateServer.createServer(); cliCreateServer.createServer();
Properties brokerProperties = new Properties(); Properties brokerProperties = new Properties();

8
tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/ReplicatedBothNodesMirrorTest.java
View File

@ -151,7 +151,7 @@ public class ReplicatedBothNodesMirrorTest extends SoakTestBase {
private static void createMirroredServer(String serverName, private static void createMirroredServer(String serverName,
String connectionName, String connectionName,
String mirrorURI, String mirrorURI,
int porOffset, int portOffset,
boolean replicated, boolean replicated,
String clusterStatic) throws Exception { String clusterStatic) throws Exception {
File serverLocation = getFileServerLocation(serverName); File serverLocation = getFileServerLocation(serverName);
@ -166,7 +166,7 @@ public class ReplicatedBothNodesMirrorTest extends SoakTestBase {
cliCreateServer.setNoWeb(true); cliCreateServer.setNoWeb(true);
cliCreateServer.setArgs("--no-stomp-acceptor", "--no-hornetq-acceptor", "--no-mqtt-acceptor", "--no-amqp-acceptor", "--max-hops", "1", "--name", DC1_NODE); 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); cliCreateServer.addArgs("--queues", QUEUE_NAME);
cliCreateServer.setPortOffset(porOffset); cliCreateServer.setPortOffset(portOffset);
if (replicated) { if (replicated) {
cliCreateServer.setReplicated(true); cliCreateServer.setReplicated(true);
cliCreateServer.setStaticCluster(clusterStatic); cliCreateServer.setStaticCluster(clusterStatic);
@ -221,7 +221,7 @@ public class ReplicatedBothNodesMirrorTest extends SoakTestBase {
} }
private static void createMirroredBackupServer(String serverName, int porOffset, String clusterStatic, String mirrorURI) throws Exception { private static void createMirroredBackupServer(String serverName, int portOffset, String clusterStatic, String mirrorURI) throws Exception {
File serverLocation = getFileServerLocation(serverName); File serverLocation = getFileServerLocation(serverName);
if (REUSE_SERVERS && serverLocation.exists()) { if (REUSE_SERVERS && serverLocation.exists()) {
deleteDirectory(new File(serverLocation, "data")); deleteDirectory(new File(serverLocation, "data"));
@ -234,7 +234,7 @@ public class ReplicatedBothNodesMirrorTest extends SoakTestBase {
cliCreateServer.setMessageLoadBalancing("ON_DEMAND"); cliCreateServer.setMessageLoadBalancing("ON_DEMAND");
cliCreateServer.setNoWeb(true); cliCreateServer.setNoWeb(true);
cliCreateServer.setArgs("--no-stomp-acceptor", "--no-hornetq-acceptor", "--no-mqtt-acceptor", "--no-amqp-acceptor", "--max-hops", "1", "--name", DC1_NODE); cliCreateServer.setArgs("--no-stomp-acceptor", "--no-hornetq-acceptor", "--no-mqtt-acceptor", "--no-amqp-acceptor", "--max-hops", "1", "--name", DC1_NODE);
cliCreateServer.setPortOffset(porOffset); cliCreateServer.setPortOffset(portOffset);
cliCreateServer.setClustered(true); cliCreateServer.setClustered(true);
cliCreateServer.setReplicated(true); cliCreateServer.setReplicated(true);
cliCreateServer.setBackup(true); cliCreateServer.setBackup(true);

8
tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/ReplicatedMirrorTargetTest.java
View File

@ -133,7 +133,7 @@ public class ReplicatedMirrorTargetTest extends SoakTestBase {
private static void createServer(String serverName, private static void createServer(String serverName,
String connectionName, String connectionName,
String mirrorURI, String mirrorURI,
int porOffset, int portOffset,
boolean paging, boolean paging,
boolean replicated, boolean replicated,
String clusterStatic) throws Exception { String clusterStatic) throws Exception {
@ -145,7 +145,7 @@ public class ReplicatedMirrorTargetTest extends SoakTestBase {
cliCreateServer.setNoWeb(false); cliCreateServer.setNoWeb(false);
cliCreateServer.setArgs("--no-stomp-acceptor", "--no-hornetq-acceptor", "--no-mqtt-acceptor", "--no-amqp-acceptor", "--max-hops", "1", "--name", DC1_NODE); cliCreateServer.setArgs("--no-stomp-acceptor", "--no-hornetq-acceptor", "--no-mqtt-acceptor", "--no-amqp-acceptor", "--max-hops", "1", "--name", DC1_NODE);
cliCreateServer.addArgs("--addresses", TOPIC_NAME); cliCreateServer.addArgs("--addresses", TOPIC_NAME);
cliCreateServer.setPortOffset(porOffset); cliCreateServer.setPortOffset(portOffset);
if (replicated) { if (replicated) {
cliCreateServer.setReplicated(true); cliCreateServer.setReplicated(true);
cliCreateServer.setStaticCluster(clusterStatic); cliCreateServer.setStaticCluster(clusterStatic);
@ -195,7 +195,7 @@ public class ReplicatedMirrorTargetTest extends SoakTestBase {
} }
private static void createBackupServer(String serverName, private static void createBackupServer(String serverName,
int porOffset, int portOffset,
String clusterStatic) throws Exception { String clusterStatic) throws Exception {
File serverLocation = getFileServerLocation(serverName); File serverLocation = getFileServerLocation(serverName);
deleteDirectory(serverLocation); deleteDirectory(serverLocation);
@ -206,7 +206,7 @@ public class ReplicatedMirrorTargetTest extends SoakTestBase {
cliCreateServer.setNoWeb(false); cliCreateServer.setNoWeb(false);
cliCreateServer.setArgs("--no-stomp-acceptor", "--no-hornetq-acceptor", "--no-mqtt-acceptor", "--no-amqp-acceptor", "--max-hops", "1", "--name", DC1_NODE); cliCreateServer.setArgs("--no-stomp-acceptor", "--no-hornetq-acceptor", "--no-mqtt-acceptor", "--no-amqp-acceptor", "--max-hops", "1", "--name", DC1_NODE);
cliCreateServer.addArgs("--addresses", TOPIC_NAME); cliCreateServer.addArgs("--addresses", TOPIC_NAME);
cliCreateServer.setPortOffset(porOffset); cliCreateServer.setPortOffset(portOffset);
cliCreateServer.setClustered(true); cliCreateServer.setClustered(true);
cliCreateServer.setReplicated(true); cliCreateServer.setReplicated(true);
cliCreateServer.setBackup(true); cliCreateServer.setBackup(true);

4
tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/SingleMirrorSoakTest.java
View File

@ -124,7 +124,7 @@ public class SingleMirrorSoakTest extends SoakTestBase {
private static void createServer(String serverName, private static void createServer(String serverName,
String connectionName, String connectionName,
String mirrorURI, String mirrorURI,
int porOffset, int portOffset,
boolean paging) throws Exception { boolean paging) throws Exception {
File serverLocation = getFileServerLocation(serverName); File serverLocation = getFileServerLocation(serverName);
deleteDirectory(serverLocation); deleteDirectory(serverLocation);
@ -136,7 +136,7 @@ public class SingleMirrorSoakTest extends SoakTestBase {
cliCreateServer.setNoWeb(false); cliCreateServer.setNoWeb(false);
cliCreateServer.setArgs("--no-stomp-acceptor", "--no-hornetq-acceptor", "--no-mqtt-acceptor", "--no-amqp-acceptor", "--max-hops", "1", "--name", DC1_NODE); cliCreateServer.setArgs("--no-stomp-acceptor", "--no-hornetq-acceptor", "--no-mqtt-acceptor", "--no-amqp-acceptor", "--max-hops", "1", "--name", DC1_NODE);
cliCreateServer.addArgs("--addresses", TOPIC_NAME); cliCreateServer.addArgs("--addresses", TOPIC_NAME);
cliCreateServer.setPortOffset(porOffset); cliCreateServer.setPortOffset(portOffset);
cliCreateServer.createServer(); cliCreateServer.createServer();
Properties brokerProperties = new Properties(); Properties brokerProperties = new Properties();

4
tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/sender/SenderSoakTest.java
View File

@ -64,7 +64,7 @@ public class SenderSoakTest extends SoakTestBase {
private static String DC1_NODEA_URI = "tcp://localhost:61616"; private static String DC1_NODEA_URI = "tcp://localhost:61616";
private static String DC2_NODEA_URI = "tcp://localhost:61618"; private static String DC2_NODEA_URI = "tcp://localhost:61618";
private static void createServer(String serverName, int porOffset) throws Exception { private static void createServer(String serverName, int portOffset) throws Exception {
File serverLocation = getFileServerLocation(serverName); File serverLocation = getFileServerLocation(serverName);
deleteDirectory(serverLocation); deleteDirectory(serverLocation);
@ -76,7 +76,7 @@ public class SenderSoakTest extends SoakTestBase {
cliCreateServer.setArgs("--no-stomp-acceptor", "--no-hornetq-acceptor", "--no-mqtt-acceptor", "--no-amqp-acceptor", "--max-hops", "1", "--name", DC1_NODE_A); cliCreateServer.setArgs("--no-stomp-acceptor", "--no-hornetq-acceptor", "--no-mqtt-acceptor", "--no-amqp-acceptor", "--max-hops", "1", "--name", DC1_NODE_A);
cliCreateServer.addArgs("--addresses", "order"); cliCreateServer.addArgs("--addresses", "order");
cliCreateServer.addArgs("--queues", "myQueue"); cliCreateServer.addArgs("--queues", "myQueue");
cliCreateServer.setPortOffset(porOffset); cliCreateServer.setPortOffset(portOffset);
cliCreateServer.createServer(); cliCreateServer.createServer();
} }