|
18 | 18 | */ |
19 | 19 | package org.apache.pulsar.client.impl; |
20 | 20 |
|
| 21 | +import static org.mockito.ArgumentMatchers.any; |
| 22 | +import static org.mockito.Mockito.doAnswer; |
| 23 | +import static org.mockito.Mockito.spy; |
21 | 24 | import com.google.common.collect.Sets; |
22 | 25 | import io.netty.buffer.ByteBuf; |
23 | 26 | import java.util.ArrayList; |
|
50 | 53 | import org.apache.pulsar.client.api.RawMessage; |
51 | 54 | import org.apache.pulsar.client.api.RawReader; |
52 | 55 | import org.apache.pulsar.client.api.Schema; |
53 | | -import org.apache.pulsar.client.api.SubscriptionInitialPosition; |
54 | | -import org.apache.pulsar.client.api.SubscriptionType; |
55 | | -import org.apache.pulsar.client.impl.conf.ConsumerConfigurationData; |
56 | | -import org.apache.pulsar.common.api.proto.BrokerEntryMetadata; |
57 | 56 | import org.apache.pulsar.common.api.proto.MessageMetadata; |
58 | 57 | import org.apache.pulsar.common.policies.data.ClusterData; |
59 | 58 | import org.apache.pulsar.common.policies.data.TenantInfoImpl; |
|
67 | 66 | import org.testng.annotations.BeforeMethod; |
68 | 67 | import org.testng.annotations.Test; |
69 | 68 |
|
70 | | -import static org.apache.pulsar.client.impl.RawReaderImpl.DEFAULT_RECEIVER_QUEUE_SIZE; |
71 | | -import static org.mockito.ArgumentMatchers.any; |
72 | | -import static org.mockito.Mockito.doAnswer; |
73 | | -import static org.mockito.Mockito.spy; |
74 | | - |
75 | 69 | @Test(groups = "broker-impl") |
76 | 70 | @Slf4j |
77 | 71 | public class RawReaderTest extends MockedPulsarServiceBaseTest { |
@@ -448,7 +442,7 @@ public void testAcknowledgeWithProperties() throws Exception { |
448 | 442 | ManagedLedger ledger = topicRef.getManagedLedger(); |
449 | 443 |
|
450 | 444 | Awaitility.await() |
451 | | - |
| 445 | + |
452 | 446 | .untilAsserted(() -> |
453 | 447 | Assert.assertEquals( |
454 | 448 | ledger.openCursor(subscription).getProperties().get("foobar"), |
|
0 commit comments