This is an automated email from the ASF dual-hosted git repository. lhotari pushed a commit to branch branch-3.0 in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/branch-3.0 by this push: new b92af789530 Fix codestyle in RawReaderTest b92af789530 is described below commit b92af789530028ac7a06e58bd16c6a7ee8edadb4 Author: Lari Hotari <lhot...@apache.org> AuthorDate: Thu Jun 19 19:18:34 2025 +0300 Fix codestyle in RawReaderTest --- .../java/org/apache/pulsar/client/impl/RawReaderTest.java | 14 ++++---------- 1 file changed, 4 insertions(+), 10 deletions(-) diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/RawReaderTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/RawReaderTest.java index 99851bcbbd4..b9314755c71 100644 --- a/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/RawReaderTest.java +++ b/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/RawReaderTest.java @@ -18,6 +18,9 @@ */ package org.apache.pulsar.client.impl; +import static org.mockito.ArgumentMatchers.any; +import static org.mockito.Mockito.doAnswer; +import static org.mockito.Mockito.spy; import com.google.common.collect.Sets; import io.netty.buffer.ByteBuf; import java.util.ArrayList; @@ -50,10 +53,6 @@ import org.apache.pulsar.client.api.PulsarClientException; import org.apache.pulsar.client.api.RawMessage; import org.apache.pulsar.client.api.RawReader; import org.apache.pulsar.client.api.Schema; -import org.apache.pulsar.client.api.SubscriptionInitialPosition; -import org.apache.pulsar.client.api.SubscriptionType; -import org.apache.pulsar.client.impl.conf.ConsumerConfigurationData; -import org.apache.pulsar.common.api.proto.BrokerEntryMetadata; import org.apache.pulsar.common.api.proto.MessageMetadata; import org.apache.pulsar.common.policies.data.ClusterData; import org.apache.pulsar.common.policies.data.TenantInfoImpl; @@ -67,11 +66,6 @@ import org.testng.annotations.AfterMethod; import org.testng.annotations.BeforeMethod; import org.testng.annotations.Test; -import static org.apache.pulsar.client.impl.RawReaderImpl.DEFAULT_RECEIVER_QUEUE_SIZE; -import static org.mockito.ArgumentMatchers.any; -import static org.mockito.Mockito.doAnswer; -import static org.mockito.Mockito.spy; - @Test(groups = "broker-impl") @Slf4j public class RawReaderTest extends MockedPulsarServiceBaseTest { @@ -448,7 +442,7 @@ public class RawReaderTest extends MockedPulsarServiceBaseTest { ManagedLedger ledger = topicRef.getManagedLedger(); Awaitility.await() - + .untilAsserted(() -> Assert.assertEquals( ledger.openCursor(subscription).getProperties().get("foobar"),