diff --git a/tests/extra-tests/src/test/java/org/apache/activemq/artemis/tests/extras/byteman/ClosingConnectionTest.java b/tests/extra-tests/src/test/java/org/apache/activemq/artemis/tests/extras/byteman/ClosingConnectionTest.java index 8515d11b99..249505d0a8 100644 --- a/tests/extra-tests/src/test/java/org/apache/activemq/artemis/tests/extras/byteman/ClosingConnectionTest.java +++ b/tests/extra-tests/src/test/java/org/apache/activemq/artemis/tests/extras/byteman/ClosingConnectionTest.java @@ -125,7 +125,7 @@ public class ClosingConnectionTest extends ActiveMQTestBase @BMRule ( name = "rule to kill connection", - targetClass = "org.apache.activemq.artemis.core.journal.impl.NIOSequentialFile", + targetClass = "org.apache.activemq.artemis.core.io.nio.NIOSequentialFile", targetMethod = "open(int, boolean)", targetLocation = "AT INVOKE java.nio.channels.FileChannel.size()", action = "org.apache.activemq.artemis.tests.extras.byteman.ClosingConnectionTest.killConnection();" diff --git a/tests/extra-tests/src/test/java/org/apache/activemq/artemis/tests/extras/byteman/PagingLeakTest.java b/tests/extra-tests/src/test/java/org/apache/activemq/artemis/tests/extras/byteman/PagingLeakTest.java index 0bbebc8617..c5d7a13680 100644 --- a/tests/extra-tests/src/test/java/org/apache/activemq/artemis/tests/extras/byteman/PagingLeakTest.java +++ b/tests/extra-tests/src/test/java/org/apache/activemq/artemis/tests/extras/byteman/PagingLeakTest.java @@ -16,6 +16,10 @@ */ package org.apache.activemq.artemis.tests.extras.byteman; +import java.util.ArrayList; +import java.util.List; +import java.util.concurrent.atomic.AtomicInteger; + import org.apache.activemq.artemis.api.core.SimpleString; import org.apache.activemq.artemis.api.core.client.ClientConsumer; import org.apache.activemq.artemis.api.core.client.ClientMessage; @@ -38,10 +42,6 @@ import org.junit.Before; import org.junit.Test; import org.junit.runner.RunWith; -import java.util.ArrayList; -import java.util.List; -import java.util.concurrent.atomic.AtomicInteger; - @RunWith(BMUnitRunner.class) public class PagingLeakTest extends ActiveMQTestBase { @@ -122,7 +122,7 @@ public class PagingLeakTest extends ActiveMQTestBase // A backup that will be waiting to be activated Configuration config = createDefaultNettyConfig(); - config.setJournalBufferTimeout_AIO(0).setJournalBufferTimeout_NIO(0); + config.setJournalBufferTimeout_AIO(10).setJournalBufferTimeout_NIO(10); final ActiveMQServer server = addServer(ActiveMQServers.newActiveMQServer(config, true)); diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/bridge/BridgeTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/bridge/BridgeTest.java index 151e2b4d5a..470ae07b3d 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/bridge/BridgeTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/bridge/BridgeTest.java @@ -1345,7 +1345,7 @@ public class BridgeTest extends ActiveMQTestBase Map server1Params = new HashMap(); addTargetParameters(server1Params); server1 = createClusteredServerWithParams(isNetty(), 1, true, PAGE_SIZE, PAGE_MAX, server1Params); - server1.getConfiguration().setJournalBufferTimeout_AIO(0).setJournalBufferTimeout_NIO(0); + server1.getConfiguration().setJournalBufferTimeout_AIO(10).setJournalBufferTimeout_NIO(10); final String testAddress = "testAddress"; final String queueName0 = "queue0"; @@ -1360,7 +1360,7 @@ public class BridgeTest extends ActiveMQTestBase server0.getConfiguration().setConnectorConfigurations(connectors); - server0.getConfiguration().setIDCacheSize(20000).setJournalBufferTimeout_NIO(0).setJournalBufferTimeout_AIO(0); + server0.getConfiguration().setIDCacheSize(20000).setJournalBufferTimeout_NIO(10).setJournalBufferTimeout_AIO(10); ArrayList staticConnectors = new ArrayList(); staticConnectors.add(server1tc.getName());