(pulsar) branch master updated: [fix][test] Recreate EventLoop in PublishRateLimiterTest setup (#25560)

[mmerli]

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

merlimat 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 293eafc08c9 [fix][test] Recreate EventLoop in PublishRateLimiterTest 
setup (#25560)
293eafc08c9 is described below

commit 293eafc08c933bbb4ffebb37c128c4b76b6a3947
Author: Matteo Merli <mme...@apache.org>
AuthorDate: Tue Apr 21 15:54:17 2026 -0700

    [fix][test] Recreate EventLoop in PublishRateLimiterTest setup (#25560)
---
 .../org/apache/pulsar/broker/service/PublishRateLimiterTest.java     | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git 
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/PublishRateLimiterTest.java
 
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/PublishRateLimiterTest.java
index 270286419f7..03283865761 100644
--- 
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/PublishRateLimiterTest.java
+++ 
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/PublishRateLimiterTest.java
@@ -57,11 +57,12 @@ public class PublishRateLimiterTest {
     private ServerCnx serverCnx;
     private PublishRateLimiterImpl publishRateLimiter;
     private ServerCnxThrottleTracker throttleTracker;
-    private DefaultThreadFactory threadFactory = new 
DefaultThreadFactory("pulsar-io");
-    private EventLoop eventLoop = new DefaultEventLoop(threadFactory);
+    private final DefaultThreadFactory threadFactory = new 
DefaultThreadFactory("pulsar-io");
+    private EventLoop eventLoop;
 
     @BeforeMethod
     public void setup() throws Exception {
+        eventLoop = new DefaultEventLoop(threadFactory);
         policies.publishMaxMessageRate = new HashMap<>();
         policies.publishMaxMessageRate.put(CLUSTER_NAME, publishRate);
         manualClockSource = new AtomicLong(TimeUnit.SECONDS.toNanos(100));