This is an automated email from the ASF dual-hosted git repository.
vavrtom pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/qpid-broker-j.git
The following commit(s) were added to refs/heads/main by this push:
new f944601b82 QPID-8615: [Broker-J] JUnit 5 migration (#221)
f944601b82 is described below
commit f944601b82053e23a32df16d087829169c34c439
Author: Daniil Kirilyuk <[email protected]>
AuthorDate: Thu Aug 24 07:56:11 2023 +0200
QPID-8615: [Broker-J] JUnit 5 migration (#221)
Fixes system tests failure in MultiNodeTest and BDBUpgradeTest
---
.../server/store/berkeleydb/BDBUpgradeTest.java | 7 ++---
.../berkeleydb/replication/GroupJmsTestBase.java | 36 ++++++++++------------
2 files changed, 19 insertions(+), 24 deletions(-)
diff --git
a/bdbstore/systests/src/test/java/org/apache/qpid/server/store/berkeleydb/BDBUpgradeTest.java
b/bdbstore/systests/src/test/java/org/apache/qpid/server/store/berkeleydb/BDBUpgradeTest.java
index 724c37834f..deda92de75 100644
---
a/bdbstore/systests/src/test/java/org/apache/qpid/server/store/berkeleydb/BDBUpgradeTest.java
+++
b/bdbstore/systests/src/test/java/org/apache/qpid/server/store/berkeleydb/BDBUpgradeTest.java
@@ -29,6 +29,7 @@ import static org.junit.jupiter.api.Assertions.assertNotNull;
import static org.junit.jupiter.api.Assertions.assertNull;
import static org.junit.jupiter.api.Assertions.assertTrue;
import static org.junit.jupiter.api.Assertions.fail;
+import static org.junit.jupiter.api.Assumptions.assumeFalse;
import static org.junit.jupiter.api.Assumptions.assumeTrue;
import java.util.Collection;
@@ -68,13 +69,11 @@ import org.apache.qpid.tests.utils.ConfigItem;
* <p>
* Store prepared using old client/broker with BDBStoreUpgradeTestPreparer.
*/
-@ConfigItem(name = "qpid.initialConfigurationLocation", value =
DEFAULT_BROKER_CONFIG )
+@ConfigItem(name = "qpid.initialConfigurationLocation", value =
DEFAULT_BROKER_CONFIG)
public class BDBUpgradeTest extends UpgradeTestBase
{
-
private static final String STRING_1024 = generateString(1024);
private static final String STRING_1024_256 = generateString(1024 * 256);
-
private static final String TOPIC_NAME = "myUpgradeTopic";
private static final String SUB_NAME = "myDurSubName";
private static final String SELECTOR_SUB_NAME = "mySelectorDurSubName";
@@ -88,7 +87,7 @@ public class BDBUpgradeTest extends UpgradeTestBase
{
assumeTrue("BDB".equals(System.getProperty("virtualhostnode.type",
"BDB")),
"System property 'virtualhostnode.type' should be 'BDB'");
- assumeTrue(Objects.equal(getProtocol(), Protocol.AMQP_1_0), "AMQP
protocol should be 1.0");
+ assumeFalse(Objects.equal(getProtocol(), Protocol.AMQP_1_0), "AMQP
protocol should be 1.0");
}
/**
diff --git
a/bdbstore/systests/src/test/java/org/apache/qpid/server/store/berkeleydb/replication/GroupJmsTestBase.java
b/bdbstore/systests/src/test/java/org/apache/qpid/server/store/berkeleydb/replication/GroupJmsTestBase.java
index f9d27194af..7d72b07a97 100644
---
a/bdbstore/systests/src/test/java/org/apache/qpid/server/store/berkeleydb/replication/GroupJmsTestBase.java
+++
b/bdbstore/systests/src/test/java/org/apache/qpid/server/store/berkeleydb/replication/GroupJmsTestBase.java
@@ -36,28 +36,26 @@ import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.AfterAll;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.BeforeAll;
-import org.junit.jupiter.api.extension.BeforeAllCallback;
-import org.junit.jupiter.api.extension.ExtensionContext;
-import org.junit.jupiter.api.extension.RegisterExtension;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
+import org.junit.jupiter.api.TestInfo;
+import org.junit.jupiter.api.TestInstance;
import org.apache.qpid.systests.ConnectionBuilder;
import org.apache.qpid.systests.JmsProvider;
import org.apache.qpid.systests.Utils;
-import org.apache.qpid.test.utils.UnitTestBase;
-public class GroupJmsTestBase extends UnitTestBase
+@TestInstance(TestInstance.Lifecycle.PER_METHOD)
+public class GroupJmsTestBase
{
private static final int FAILOVER_CYCLECOUNT = 40;
private static final int FAILOVER_CONNECTDELAY = 1000;
static final int SHORT_FAILOVER_CYCLECOUNT = 2;
static final int SHORT_FAILOVER_CONNECTDELAY = 200;
+ private static final AtomicReference<Class<?>> _testClass = new
AtomicReference<>();
- private static final Logger LOGGER =
LoggerFactory.getLogger(GroupJmsTestBase.class);
private static JmsProvider _jmsProvider;
private static GroupBrokerAdmin _groupBrokerAdmin;
- private static AtomicReference<Class<?>> _testClass = new
AtomicReference<>();
+
+ private String _testName;
@BeforeAll
public static void setUpTestBase()
@@ -78,26 +76,24 @@ public class GroupJmsTestBase extends UnitTestBase
}
}
- @RegisterExtension
- public final BeforeAllCallback resource = (ExtensionContext ctx) ->
+ @BeforeEach
+ public void beforeTestMethod(final TestInfo testInfo) throws Exception
{
if (_testClass.compareAndSet(null, GroupJmsTestBase.this.getClass() ))
{
_groupBrokerAdmin = new GroupBrokerAdmin();
_groupBrokerAdmin.beforeTestClass(GroupJmsTestBase.this.getClass());
}
- };
-
- @BeforeEach
- public void beforeTestMethod() throws Exception
- {
- _groupBrokerAdmin.beforeTestMethod(getClass(),
getClass().getMethod(getTestName()));
+ _testName = testInfo.getTestMethod()
+ .orElseThrow(() -> new RuntimeException("Failed to resolve
test method"))
+ .getName();
+ _groupBrokerAdmin.beforeTestMethod(getClass(),
getClass().getMethod(_testName));
}
@AfterEach
public void afterTestMethod() throws Exception
{
- _groupBrokerAdmin.afterTestMethod(getClass(),
getClass().getMethod(getTestName()));
+ _groupBrokerAdmin.afterTestMethod(getClass(),
getClass().getMethod(_testName));
}
GroupBrokerAdmin getBrokerAdmin()
@@ -108,7 +104,7 @@ public class GroupJmsTestBase extends UnitTestBase
ConnectionBuilder getConnectionBuilder()
{
final ConnectionBuilder connectionBuilder =
_jmsProvider.getConnectionBuilder()
-
.setClientId(getTestName())
+
.setClientId(_testName)
.setFailoverReconnectDelay(FAILOVER_CONNECTDELAY)
.setFailoverReconnectAttempts(FAILOVER_CYCLECOUNT)
.setVirtualHost("test")
@@ -154,7 +150,7 @@ public class GroupJmsTestBase extends UnitTestBase
Session session = connection.createSession(false,
Session.AUTO_ACKNOWLEDGE);
try
{
- return getJmsProvider().createQueue(session, getTestName());
+ return getJmsProvider().createQueue(session, _testName);
}
finally
{
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
