(pulsar) branch master updated: [fix][broker]: fix irregular method name (#23108)

[xiangying]

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

xiangying 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 92bcd077c01 [fix][broker]: fix irregular method name (#23108)
92bcd077c01 is described below

commit 92bcd077c01058597fb910a49cbe01dffea41b36
Author: Aurora Twinkle <foreverlove...@gmail.com>
AuthorDate: Wed Jul 31 21:42:56 2024 +0800

    [fix][broker]: fix irregular method name (#23108)
    
    Co-authored-by: duanlinlin <duanlinl...@xiaohongshu.com>
    
    Fixes: fix irregular method name
---
 .../src/main/java/org/apache/pulsar/broker/PulsarService.java         | 2 +-
 .../java/org/apache/pulsar/client/api/OrphanPersistentTopicTest.java  | 4 ++--
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java
index b23851a5ec4..060e905d1f3 100644
--- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java
+++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java
@@ -2016,7 +2016,7 @@ public class PulsarService implements AutoCloseable, 
ShutdownService {
     }
 
     @VisibleForTesting
-    public void setTransactionExecutorProvider(TransactionBufferProvider 
transactionBufferProvider) {
+    public void setTransactionBufferProvider(TransactionBufferProvider 
transactionBufferProvider) {
         this.transactionBufferProvider = transactionBufferProvider;
     }
 
diff --git 
a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/OrphanPersistentTopicTest.java
 
b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/OrphanPersistentTopicTest.java
index d6473efd788..b5af3cc6afd 100644
--- 
a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/OrphanPersistentTopicTest.java
+++ 
b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/OrphanPersistentTopicTest.java
@@ -152,7 +152,7 @@ public class OrphanPersistentTopicTest extends 
ProducerConsumerBase {
             }
         };
         TransactionBufferProvider originalTransactionBufferProvider = 
pulsar.getTransactionBufferProvider();
-        pulsar.setTransactionExecutorProvider(mockTransactionBufferProvider);
+        pulsar.setTransactionBufferProvider(mockTransactionBufferProvider);
         CompletableFuture<Optional<Topic>> firstLoad = 
pulsar.getBrokerService().getTopic(tpName, true);
         Awaitility.await().ignoreExceptions().atMost(5, TimeUnit.SECONDS)
                 .pollInterval(100, TimeUnit.MILLISECONDS)
@@ -170,7 +170,7 @@ public class OrphanPersistentTopicTest extends 
ProducerConsumerBase {
         }
 
         // set to back
-        
pulsar.setTransactionExecutorProvider(originalTransactionBufferProvider);
+        pulsar.setTransactionBufferProvider(originalTransactionBufferProvider);
         
pulsar.getConfig().setTopicLoadTimeoutSeconds(originalTopicLoadTimeoutSeconds);
         pulsar.getConfig().setBrokerDeduplicationEnabled(false);
         pulsar.getConfig().setTransactionCoordinatorEnabled(false);