Skip to content

Commit

Permalink
NO-JIRA Fixing typo on porOffset -> portOffset
Browse files Browse the repository at this point in the history
  • Loading branch information
@clebertsuconic
clebertsuconic committed Aug 20, 2024
1 parent d41f01a commit ac666f3
Show file tree
Hide file tree
Showing 13 changed files with 32 additions and 32 deletions.
4 changes: 2 additions & 2 deletions .../java/org/apache/activemq/artemis/tests/smoke/brokerConnection/DivertQueueMirrorTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -75,7 +75,7 @@ public class DivertQueueMirrorTest extends SmokeTestBase {
private static void createServer(String serverName,
String connectionName,
String mirrorURI,
int porOffset) throws Exception {
int portOffset) throws Exception {
File serverLocation = getFileServerLocation(serverName);
deleteDirectory(serverLocation);

Expand All @@ -87,7 +87,7 @@ private static void createServer(String serverName,
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("--java-memory", "512M");
cliCreateServer.setPortOffset(porOffset);
cliCreateServer.setPortOffset(portOffset);
cliCreateServer.createServer();

Properties brokerProperties = new Properties();
Expand Down
8 changes: 4 additions & 4 deletions .../apache/activemq/artemis/tests/smoke/brokerConnection/MirrorInfiniteRetryReplicaTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -97,7 +97,7 @@ private static String uriWithAlternate(String ip, String alternate) {
private static void createMirroredServer(String serverName,
String connectionName,
String mirrorURI,
int porOffset,
int portOffset,
boolean replicated,
String clusterStatic) throws Exception {
File serverLocation = getFileServerLocation(serverName);
Expand All @@ -108,7 +108,7 @@ private static void createMirroredServer(String serverName,
cliCreateServer.setNoWeb(true);
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.setPortOffset(porOffset);
cliCreateServer.setPortOffset(portOffset);
if (replicated) {
cliCreateServer.setReplicated(true);
cliCreateServer.setStaticCluster(clusterStatic);
Expand Down Expand Up @@ -162,7 +162,7 @@ private static void replaceLogs(File serverLocation) throws Exception {
}

private static void createMirroredBackupServer(String serverName,
int porOffset,
int portOffset,
String clusterStatic,
String mirrorURI) throws Exception {
File serverLocation = getFileServerLocation(serverName);
Expand All @@ -173,7 +173,7 @@ private static void createMirroredBackupServer(String serverName,
cliCreateServer.setMessageLoadBalancing("ON_DEMAND");
cliCreateServer.setNoWeb(true);
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.setReplicated(true);
cliCreateServer.setBackup(true);
Expand Down
4 changes: 2 additions & 2 deletions ...apache/activemq/artemis/tests/soak/brokerConnection/mirror/AccumulatedInPageSoakTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -81,7 +81,7 @@ public class AccumulatedInPageSoakTest extends SoakTestBase {
private static void createServer(String serverName,
String connectionName,
String mirrorURI,
int porOffset) throws Exception {
int portOffset) throws Exception {
File serverLocation = getFileServerLocation(serverName);
deleteDirectory(serverLocation);

Expand All @@ -93,7 +93,7 @@ private static void createServer(String serverName,
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("--java-memory", "512M");
cliCreateServer.setPortOffset(porOffset);
cliCreateServer.setPortOffset(portOffset);
cliCreateServer.createServer();

Properties brokerProperties = new Properties();
Expand Down
4 changes: 2 additions & 2 deletions ...g/apache/activemq/artemis/tests/soak/brokerConnection/mirror/ClusteredMirrorSoakTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -93,7 +93,7 @@ public class ClusteredMirrorSoakTest extends SoakTestBase {
private static String DC2_NODEA_URI = "tcp://localhost:61618";
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);
deleteDirectory(serverLocation);

Expand All @@ -106,7 +106,7 @@ private static void createServer(String serverName, String connectionName, Strin
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("--queues", "myQueue");
cliCreateServer.setPortOffset(porOffset);
cliCreateServer.setPortOffset(portOffset);
cliCreateServer.createServer();

Properties brokerProperties = new Properties();
Expand Down
4 changes: 2 additions & 2 deletions ...ava/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/IdempotentACKTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -81,7 +81,7 @@ public class IdempotentACKTest extends SoakTestBase {
private static void createServer(String serverName,
String connectionName,
String mirrorURI,
int porOffset) throws Exception {
int portOffset) throws Exception {
File serverLocation = getFileServerLocation(serverName);
deleteDirectory(serverLocation);

Expand All @@ -92,7 +92,7 @@ private static void createServer(String serverName,
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.addArgs("--queues", QUEUE_NAME);
cliCreateServer.setPortOffset(porOffset);
cliCreateServer.setPortOffset(portOffset);
cliCreateServer.createServer();

Properties brokerProperties = new Properties();
Expand Down
4 changes: 2 additions & 2 deletions ...ache/activemq/artemis/tests/soak/brokerConnection/mirror/InterruptedLargeMessageTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -85,7 +85,7 @@ public class InterruptedLargeMessageTest extends SoakTestBase {
private static void createServer(String serverName,
String connectionName,
String mirrorURI,
int porOffset) throws Exception {
int portOffset) throws Exception {
File serverLocation = getFileServerLocation(serverName);
deleteDirectory(serverLocation);

Expand All @@ -96,7 +96,7 @@ private static void createServer(String serverName,
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.addArgs("--queues", QUEUE_NAME);
cliCreateServer.setPortOffset(porOffset);
cliCreateServer.setPortOffset(portOffset);
cliCreateServer.createServer();

Properties brokerProperties = new Properties();
Expand Down
4 changes: 2 additions & 2 deletions ...a/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/MultiMirrorSoakTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -74,7 +74,7 @@ public class MultiMirrorSoakTest extends SoakTestBase {
private static String DC3_NODEA_URI = "tcp://localhost:61618";

private static void createServer(String serverName,
int porOffset,
int portOffset,
boolean paging,
String... mirrorTo) throws Exception {
File serverLocation = getFileServerLocation(serverName);
Expand All @@ -88,7 +88,7 @@ private static void createServer(String serverName,
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("--queues", "myQueue");
cliCreateServer.setPortOffset(porOffset);
cliCreateServer.setPortOffset(portOffset);
cliCreateServer.createServer();

Properties brokerProperties = new Properties();
Expand Down
4 changes: 2 additions & 2 deletions ...java/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/PagedSNFSoakTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -80,7 +80,7 @@ public class PagedSNFSoakTest extends SoakTestBase {
private static void createServer(String serverName,
String connectionName,
String mirrorURI,
int porOffset) throws Exception {
int portOffset) throws Exception {
File serverLocation = getFileServerLocation(serverName);
deleteDirectory(serverLocation);

Expand All @@ -92,7 +92,7 @@ private static void createServer(String serverName,
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("--java-memory", "512M");
cliCreateServer.setPortOffset(porOffset);
cliCreateServer.setPortOffset(portOffset);
cliCreateServer.createServer();

Properties brokerProperties = new Properties();
Expand Down
4 changes: 2 additions & 2 deletions ...va/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/QuickAckMirrorTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -62,7 +62,7 @@ public class QuickAckMirrorTest extends SoakTestBase {
private static void createServer(String serverName,
String connectionName,
String mirrorURI,
int porOffset) throws Exception {
int portOffset) throws Exception {
File serverLocation = getFileServerLocation(serverName);
deleteDirectory(serverLocation);

Expand All @@ -73,7 +73,7 @@ private static void createServer(String serverName,
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.addArgs("--queues", QUEUE_NAME);
cliCreateServer.setPortOffset(porOffset);
cliCreateServer.setPortOffset(portOffset);
cliCreateServer.createServer();

Properties brokerProperties = new Properties();
Expand Down
8 changes: 4 additions & 4 deletions ...he/activemq/artemis/tests/soak/brokerConnection/mirror/ReplicatedBothNodesMirrorTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -151,7 +151,7 @@ private void startDC1(SimpleManagement managementDC1) throws Exception {
private static void createMirroredServer(String serverName,
String connectionName,
String mirrorURI,
int porOffset,
int portOffset,
boolean replicated,
String clusterStatic) throws Exception {
File serverLocation = getFileServerLocation(serverName);
Expand All @@ -166,7 +166,7 @@ private static void createMirroredServer(String serverName,
cliCreateServer.setNoWeb(true);
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.setPortOffset(porOffset);
cliCreateServer.setPortOffset(portOffset);
if (replicated) {
cliCreateServer.setReplicated(true);
cliCreateServer.setStaticCluster(clusterStatic);
Expand Down Expand Up @@ -221,7 +221,7 @@ private static void replaceLogs(File serverLocation) throws Exception {

}

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);
if (REUSE_SERVERS && serverLocation.exists()) {
deleteDirectory(new File(serverLocation, "data"));
Expand All @@ -234,7 +234,7 @@ private static void createMirroredBackupServer(String serverName, int porOffset,
cliCreateServer.setMessageLoadBalancing("ON_DEMAND");
cliCreateServer.setNoWeb(true);
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.setReplicated(true);
cliCreateServer.setBackup(true);
Expand Down
8 changes: 4 additions & 4 deletions ...pache/activemq/artemis/tests/soak/brokerConnection/mirror/ReplicatedMirrorTargetTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -133,7 +133,7 @@ public void destroyServers() throws Exception {
private static void createServer(String serverName,
String connectionName,
String mirrorURI,
int porOffset,
int portOffset,
boolean paging,
boolean replicated,
String clusterStatic) throws Exception {
Expand All @@ -145,7 +145,7 @@ private static void createServer(String serverName,
cliCreateServer.setNoWeb(false);
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.setPortOffset(porOffset);
cliCreateServer.setPortOffset(portOffset);
if (replicated) {
cliCreateServer.setReplicated(true);
cliCreateServer.setStaticCluster(clusterStatic);
Expand Down Expand Up @@ -195,7 +195,7 @@ private static void replaceLogs(File serverLocation) throws Exception {
}

private static void createBackupServer(String serverName,
int porOffset,
int portOffset,
String clusterStatic) throws Exception {
File serverLocation = getFileServerLocation(serverName);
deleteDirectory(serverLocation);
Expand All @@ -206,7 +206,7 @@ private static void createBackupServer(String serverName,
cliCreateServer.setNoWeb(false);
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.setPortOffset(porOffset);
cliCreateServer.setPortOffset(portOffset);
cliCreateServer.setClustered(true);
cliCreateServer.setReplicated(true);
cliCreateServer.setBackup(true);
Expand Down
4 changes: 2 additions & 2 deletions .../org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/SingleMirrorSoakTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -124,7 +124,7 @@ public void destroyServers() throws Exception {
private static void createServer(String serverName,
String connectionName,
String mirrorURI,
int porOffset,
int portOffset,
boolean paging) throws Exception {
File serverLocation = getFileServerLocation(serverName);
deleteDirectory(serverLocation);
Expand All @@ -136,7 +136,7 @@ private static void createServer(String serverName,
cliCreateServer.setNoWeb(false);
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.setPortOffset(porOffset);
cliCreateServer.setPortOffset(portOffset);
cliCreateServer.createServer();

Properties brokerProperties = new Properties();
Expand Down
4 changes: 2 additions & 2 deletions ...t/java/org/apache/activemq/artemis/tests/soak/brokerConnection/sender/SenderSoakTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -64,7 +64,7 @@ public class SenderSoakTest extends SoakTestBase {
private static String DC1_NODEA_URI = "tcp://localhost:61616";
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);
deleteDirectory(serverLocation);

Expand All @@ -76,7 +76,7 @@ private static void createServer(String serverName, int porOffset) throws Except
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("--queues", "myQueue");
cliCreateServer.setPortOffset(porOffset);
cliCreateServer.setPortOffset(portOffset);
cliCreateServer.createServer();
}

Expand Down

0 comments on commit ac666f3

Please sign in to comment.