[pulsar] branch master updated: [fix][broker] Fix typos in Subscription interface (#21321)

[technoboy]

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 b6a593cd018 [fix][broker] Fix typos in Subscription interface (#21321)
b6a593cd018 is described below

commit b6a593cd018a4124a6ce30720a001d6184603783
Author: hanmz <gunn...@tencent.com>
AuthorDate: Thu Oct 19 22:02:17 2023 +0800

    [fix][broker] Fix typos in Subscription interface (#21321)
---
 .../src/main/java/org/apache/pulsar/broker/service/Consumer.java        | 2 +-
 .../src/main/java/org/apache/pulsar/broker/service/Subscription.java    | 2 +-
 .../pulsar/broker/service/nonpersistent/NonPersistentSubscription.java  | 2 +-
 .../apache/pulsar/broker/service/persistent/PersistentSubscription.java | 2 +-
 .../org/apache/pulsar/broker/service/persistent/PersistentTopic.java    | 2 +-
 5 files changed, 5 insertions(+), 5 deletions(-)

diff --git 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Consumer.java 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Consumer.java
index 68678efc296..023ede74b4f 100644
--- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Consumer.java
+++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Consumer.java
@@ -820,7 +820,7 @@ public class Consumer {
     }
 
     public boolean checkAndApplyTopicMigration() {
-        if (subscription.isSubsciptionMigrated()) {
+        if (subscription.isSubscriptionMigrated()) {
             Optional<ClusterUrl> clusterUrl = 
AbstractTopic.getMigratedClusterUrl(cnx.getBrokerService().getPulsar(),
                     topicName);
             if (clusterUrl.isPresent()) {
diff --git 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Subscription.java
 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Subscription.java
index be079c2b4b5..9deeafdb272 100644
--- 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Subscription.java
+++ 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Subscription.java
@@ -102,7 +102,7 @@ public interface Subscription extends MessageExpirer {
 
     CompletableFuture<Void> updateSubscriptionProperties(Map<String, String> 
subscriptionProperties);
 
-    boolean isSubsciptionMigrated();
+    boolean isSubscriptionMigrated();
 
     default void 
processReplicatedSubscriptionSnapshot(ReplicatedSubscriptionsSnapshot snapshot) 
{
         // Default is no-op
diff --git 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentSubscription.java
 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentSubscription.java
index 7cd4d8984c8..6e9e5259027 100644
--- 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentSubscription.java
+++ 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentSubscription.java
@@ -272,7 +272,7 @@ public class NonPersistentSubscription extends 
AbstractSubscription implements S
     }
 
     @Override
-    public boolean isSubsciptionMigrated() {
+    public boolean isSubscriptionMigrated() {
         return topic.isMigrated();
     }
 
diff --git 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentSubscription.java
 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentSubscription.java
index 1f6f688d86f..d152842b31c 100644
--- 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentSubscription.java
+++ 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentSubscription.java
@@ -1259,7 +1259,7 @@ public class PersistentSubscription extends 
AbstractSubscription implements Subs
     }
 
     @Override
-    public boolean isSubsciptionMigrated() {
+    public boolean isSubscriptionMigrated() {
         log.info("backlog for {} - {}", topicName, 
cursor.getNumberOfEntriesInBacklog(true));
         return topic.isMigrated() && cursor.getNumberOfEntriesInBacklog(true) 
<= 0;
     }
diff --git 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java
 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java
index 4fe555aca5f..4d35d284d32 100644
--- 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java
+++ 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java
@@ -2614,7 +2614,7 @@ public class PersistentTopic extends AbstractTopic 
implements Topic, AddEntryCal
                     : CompletableFuture.completedFuture(null);
             return migrated.thenApply(__ -> {
                 subscriptions.forEach((name, sub) -> {
-                    if (sub.isSubsciptionMigrated()) {
+                    if (sub.isSubscriptionMigrated()) {
                         
sub.getConsumers().forEach(Consumer::checkAndApplyTopicMigration);
                     }
                 });