This is an automated email from the ASF dual-hosted git repository.
technoboy 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 6101517d488 [fix][test]Fix resource not close after method (#20715)
6101517d488 is described below
commit 6101517d488a734c7a75b4e2e844230856adf41c
Author: feynmanlin <[email protected]>
AuthorDate: Wed Jul 5 08:41:23 2023 +0800
[fix][test]Fix resource not close after method (#20715)
---
.../org/apache/pulsar/broker/service/PublishRateLimiterTest.java | 9 +++++++++
1 file changed, 9 insertions(+)
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 b934ced08c5..f3cb25e789f 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
@@ -21,6 +21,7 @@ package org.apache.pulsar.broker.service;
import org.apache.pulsar.common.policies.data.Policies;
import org.apache.pulsar.common.policies.data.PublishRate;
import org.apache.pulsar.common.util.RateLimiter;
+import org.testng.annotations.AfterMethod;
import org.testng.annotations.BeforeMethod;
import org.testng.annotations.Test;
@@ -51,6 +52,14 @@ public class PublishRateLimiterTest {
publishRateLimiter = new PublishRateLimiterImpl(policies,
CLUSTER_NAME);
}
+ @AfterMethod
+ public void cleanup() throws Exception {
+ policies.publishMaxMessageRate.clear();
+ policies.publishMaxMessageRate = null;
+ precisePublishLimiter.close();
+ publishRateLimiter.close();
+ }
+
@Test
public void testPublishRateLimiterImplExceed() throws Exception {
// increment not exceed