Skip to content

Commit

Permalink
fix #18491 import incorrect class
Browse files Browse the repository at this point in the history
  • Loading branch information
congbobo184 committed Nov 18, 2022
1 parent 975f643 commit 961d5b5
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -35,7 +35,7 @@
import org.apache.pulsar.client.api.Schema;
import org.apache.pulsar.client.api.SubscriptionType;
import org.awaitility.Awaitility;
import org.testcontainers.shaded.org.awaitility.reflect.WhiteboxImpl;
import org.awaitility.reflect.WhiteboxImpl;
import org.testng.Assert;
import org.testng.annotations.AfterClass;
import org.testng.annotations.BeforeClass;
Expand Down Expand Up @@ -235,7 +235,7 @@ public void run() {
Assert.assertEquals(0, datas.size());
}

@Test(invocationCount = 5)
@Test
public void testMultiTopicConsumerConcurrentRedeliverAndReceive() throws Exception {
final String topic = BrokerTestUtil.newUniqueName("my-topic");
admin.topics().createPartitionedTopic(topic, 2);
Expand Down

0 comments on commit 961d5b5

Please sign in to comment.