Skip to content

Commit 6889aaf

Browse files
author
Heesung Sohn
committed
fix GeoRepIntegTest close
1 parent e7369a9 commit 6889aaf

File tree

4 files changed

+8
-9
lines changed

4 files changed

+8
-9
lines changed

pulsar-inttest-client/src/main/java/org/apache/pulsar/tests/integration/GeoRepIntegTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -37,8 +37,8 @@ public GeoRepIntegTest(PulsarClient clientA, PulsarAdmin adminA, PulsarClient cl
3737

3838
public void close() throws IOException {
3939
clientA.close();
40+
clientB.close();
4041
adminA.close();
4142
adminB.close();
42-
adminB.close();
4343
}
4444
}

tests/integration/src/test/java/org/apache/pulsar/tests/integration/messaging/NonPersistentTopicMessaging.java renamed to tests/integration/src/test/java/org/apache/pulsar/tests/integration/messaging/NonPersistentTopicMessagingTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@
2424
import org.testng.annotations.Test;
2525

2626
@Slf4j
27-
public class NonPersistentTopicMessaging extends MessagingBase {
27+
public class NonPersistentTopicMessagingTest extends MessagingBase {
2828

2929
TopicMessaging test;
3030

tests/integration/src/test/java/org/apache/pulsar/tests/integration/messaging/PersistentTopicMessaging.java renamed to tests/integration/src/test/java/org/apache/pulsar/tests/integration/messaging/PersistentTopicMessagingTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@
2424
import org.testng.annotations.Test;
2525

2626
@Slf4j
27-
public class PersistentTopicMessaging extends MessagingBase {
27+
public class PersistentTopicMessagingTest extends MessagingBase {
2828

2929
TopicMessaging test;
3030

tests/integration/src/test/resources/pulsar-messaging.xml

Lines changed: 5 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -22,15 +22,14 @@
2222
<suite name="Pulsar (Messaging) Integration Tests" verbose="2" annotations="JDK">
2323
<test name="messaging-test-suite" preserve-order="true">
2424
<classes>
25-
<class name="org.apache.pulsar.tests.integration.messaging.PersistentTopicMessaging" />
26-
<class name="org.apache.pulsar.tests.integration.messaging.NonPersistentTopicMessaging" />
27-
<class name="org.apache.pulsar.tests.integration.messaging.GeoReplication" />
25+
<class name="org.apache.pulsar.tests.integration.messaging.PersistentTopicMessagingTest" />
26+
<class name="org.apache.pulsar.tests.integration.messaging.NonPersistentTopicMessagingTest" />
27+
<class name="org.apache.pulsar.tests.integration.messaging.GeoReplicationTest" />
2828
<class name="org.apache.pulsar.tests.integration.messaging.DelayMessagingTest" />
29-
<class name="org.apache.pulsar.tests.integration.messaging.ReaderMessaging" />
30-
<class name="org.apache.pulsar.tests.integration.messaging.NonDurableConsumerMessaging" />
29+
<class name="org.apache.pulsar.tests.integration.messaging.ReaderMessagingTest" />
30+
<class name="org.apache.pulsar.tests.integration.messaging.NonDurableConsumerMessagingTest" />
3131
<class name="org.apache.pulsar.tests.integration.messaging.MessagingSmokeTest" />
3232
<class name="org.apache.pulsar.tests.integration.admin.AdminTest" />
33-
3433
<class name="org.apache.pulsar.tests.integration.oxia.OxiaSmokeTest" />
3534
</classes>
3635
</test>

0 commit comments

Comments
 (0)