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);