|
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