[pulsar] branch master updated: Fix test org.apache.pulsar.broker.admin.PersistentTopicsTest#testUnloadTopic (#16699)

[technoboy]

This is an automated email from the ASF dual-hosted git repository.

technoboy pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new 01349088f86 Fix test 
org.apache.pulsar.broker.admin.PersistentTopicsTest#testUnloadTopic (#16699)
01349088f86 is described below

commit 01349088f86ad8034c844fb1bbe0b0c04e2c0892
Author: Xiaoyu Hou <anonhx...@gmail.com>
AuthorDate: Thu Jul 21 21:28:38 2022 +0800

    Fix test 
org.apache.pulsar.broker.admin.PersistentTopicsTest#testUnloadTopic (#16699)
---
 .../java/org/apache/pulsar/broker/admin/PersistentTopicsTest.java    | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git 
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/PersistentTopicsTest.java
 
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/PersistentTopicsTest.java
index 9fe28655594..8e53a15b066 100644
--- 
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/PersistentTopicsTest.java
+++ 
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/PersistentTopicsTest.java
@@ -639,10 +639,13 @@ public class PersistentTopicsTest extends 
MockedPulsarServiceBaseTest {
         // 2) create non partitioned topic and unload
         response = mock(AsyncResponse.class);
         persistentTopics.createNonPartitionedTopic(response, testTenant, 
testNamespace, topicName, true, null);
-        persistentTopics.unloadTopic(response, testTenant, testNamespace, 
topicName, true);
         ArgumentCaptor<Response> responseCaptor = 
ArgumentCaptor.forClass(Response.class);
         verify(response, 
timeout(5000).times(1)).resume(responseCaptor.capture());
         Assert.assertEquals(responseCaptor.getValue().getStatus(), 
Response.Status.NO_CONTENT.getStatusCode());
+        persistentTopics.unloadTopic(response, testTenant, testNamespace, 
topicName, true);
+        responseCaptor = ArgumentCaptor.forClass(Response.class);
+        verify(response, 
timeout(5000).times(1)).resume(responseCaptor.capture());
+        Assert.assertEquals(responseCaptor.getValue().getStatus(), 
Response.Status.NO_CONTENT.getStatusCode());
 
         // 3) create partitioned topic and unload
         response = mock(AsyncResponse.class);