[pulsar] branch xiangying/branch-2.10/20597 updated: overloaded method

[xiangying]

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

xiangying pushed a commit to branch xiangying/branch-2.10/20597
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/xiangying/branch-2.10/20597 by 
this push:
     new f48621103fc overloaded method
f48621103fc is described below

commit f48621103fcbd267c9bdf4df33523ba315579024
Author: xiangying <1984997...@qq.com>
AuthorDate: Wed Jul 12 09:37:02 2023 +0800

    overloaded method
---
 .../service/persistent/PersistentMessageExpiryMonitor.java | 14 ++++++++++++++
 1 file changed, 14 insertions(+)

diff --git 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentMessageExpiryMonitor.java
 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentMessageExpiryMonitor.java
index 718579db0b4..35c6b807589 100644
--- 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentMessageExpiryMonitor.java
+++ 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentMessageExpiryMonitor.java
@@ -72,6 +72,20 @@ public class PersistentMessageExpiryMonitor implements 
FindEntryCallback {
                 && 
this.cursor.getManagedLedger().getConfig().isAutoSkipNonRecoverableData();
     }
 
+    public PersistentMessageExpiryMonitor(String topicName, String 
subscriptionName, ManagedCursor cursor,
+                                          PersistentSubscription subscription) 
{
+        this.topicName = topicName;
+        this.topic = subscription.topic;
+        this.cursor = cursor;
+        this.subName = subscriptionName;
+        this.subscription = subscription;
+        this.msgExpired = new Rate();
+        this.totalMsgExpired = new LongAdder();
+        // check to avoid test failures
+        this.autoSkipNonRecoverableData = this.cursor.getManagedLedger() != 
null
+                && 
this.cursor.getManagedLedger().getConfig().isAutoSkipNonRecoverableData();
+    }
+
     public boolean expireMessages(int messageTTLInSeconds) {
         if (expirationCheckInProgressUpdater.compareAndSet(this, FALSE, TRUE)) 
{
             log.info("[{}][{}] Starting message expiry check, ttl= {} 
seconds", topicName, subName,