ARTEMIS-4651 Reverting test change on PagedMirrorSmokeTest as it wasn't needed
This commit is contained in:
parent
db94b18b73
commit
c6cf68fe5c
|
@ -25,8 +25,6 @@ import javax.jms.Queue;
|
|||
import javax.jms.Session;
|
||||
import javax.jms.TextMessage;
|
||||
import java.io.File;
|
||||
import java.nio.file.Files;
|
||||
import java.nio.file.Path;
|
||||
import java.util.HashMap;
|
||||
import java.util.concurrent.atomic.AtomicInteger;
|
||||
|
||||
|
@ -61,30 +59,13 @@ public class PagedMirrorSmokeTest extends SmokeTestBase {
|
|||
HelperCreate cliCreateServer = new HelperCreate();
|
||||
cliCreateServer.setAllowAnonymous(true).setRole("amq").setUser("artemis").setPassword("artemis").setNoWeb(true).setConfiguration("./src/main/resources/servers/brokerConnect/pagedA").setArtemisInstance(server0Location);
|
||||
cliCreateServer.createServer();
|
||||
configureAcceptor(SERVER_NAME_A);
|
||||
}
|
||||
|
||||
if (!server1Location.exists()) {
|
||||
HelperCreate cliCreateServer = new HelperCreate();
|
||||
cliCreateServer.setAllowAnonymous(true).setRole("amq").setUser("artemis").setPassword("artemis").setNoWeb(true).setConfiguration("./src/main/resources/servers/brokerConnect/pagedB").setArtemisInstance(server1Location);
|
||||
cliCreateServer.createServer();
|
||||
configureAcceptor(SERVER_NAME_B);
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
|
||||
private static void configureAcceptor(String serverName) throws Exception {
|
||||
|
||||
Path configPath = new File(getServerLocation(serverName), "./etc/broker.xml").toPath();
|
||||
|
||||
String brokerXML = Files.readString(configPath);
|
||||
|
||||
brokerXML = brokerXML.replace(";amqpDuplicateDetection=true", ";amqpDuplicateDetection=true;ackRetryInterval=100");
|
||||
Assert.assertTrue(brokerXML.contains("ackRetryInterval"));
|
||||
|
||||
Files.writeString(configPath, brokerXML);
|
||||
|
||||
}
|
||||
|
||||
|
||||
|
|
Loading…
Reference in New Issue