You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tubemq.apache.org by al...@apache.org on 2020/04/21 06:13:14 UTC
[incubator-tubemq] branch master updated: [TUBEMQ-77] fix typo (#59)
This is an automated email from the ASF dual-hosted git repository.
aloyszhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-tubemq.git
The following commit(s) were added to refs/heads/master by this push:
new 4b7a245 [TUBEMQ-77] fix typo (#59)
4b7a245 is described below
commit 4b7a24596ed954c8fdfd6088d1c3a6ff90584756
Author: Tboy <gu...@immomo.com>
AuthorDate: Tue Apr 21 14:13:03 2020 +0800
[TUBEMQ-77] fix typo (#59)
---
.../main/java/org/apache/tubemq/server/broker/BrokerServiceServer.java | 2 +-
.../org/apache/tubemq/server/broker/metadata/BrokerMetadataManage.java | 2 +-
.../java/org/apache/tubemq/server/broker/metadata/MetadataManage.java | 2 +-
3 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/tubemq-server/src/main/java/org/apache/tubemq/server/broker/BrokerServiceServer.java b/tubemq-server/src/main/java/org/apache/tubemq/server/broker/BrokerServiceServer.java
index 170ea2e..b51f618 100644
--- a/tubemq-server/src/main/java/org/apache/tubemq/server/broker/BrokerServiceServer.java
+++ b/tubemq-server/src/main/java/org/apache/tubemq/server/broker/BrokerServiceServer.java
@@ -352,7 +352,7 @@ public class BrokerServiceServer implements BrokerReadService, BrokerWriteServic
builder.setErrMsg(e.getMessage());
return builder.build();
}
- Integer topicStatusId = this.metadataManage.getCosedTopicStatusId(topicName);
+ Integer topicStatusId = this.metadataManage.getClosedTopicStatusId(topicName);
if ((topicStatusId != null)
&& (topicStatusId > TStatusConstants.STATUS_TOPIC_SOFT_DELETE)) {
strBuffer.append("[Partition Closed] Partition has been closed, for topic=")
diff --git a/tubemq-server/src/main/java/org/apache/tubemq/server/broker/metadata/BrokerMetadataManage.java b/tubemq-server/src/main/java/org/apache/tubemq/server/broker/metadata/BrokerMetadataManage.java
index bc8f85a..859cfcc 100644
--- a/tubemq-server/src/main/java/org/apache/tubemq/server/broker/metadata/BrokerMetadataManage.java
+++ b/tubemq-server/src/main/java/org/apache/tubemq/server/broker/metadata/BrokerMetadataManage.java
@@ -153,7 +153,7 @@ public class BrokerMetadataManage implements MetadataManage {
}
@Override
- public Integer getCosedTopicStatusId(final String topic) {
+ public Integer getClosedTopicStatusId(final String topic) {
return this.closedTopicMap.get(topic);
}
diff --git a/tubemq-server/src/main/java/org/apache/tubemq/server/broker/metadata/MetadataManage.java b/tubemq-server/src/main/java/org/apache/tubemq/server/broker/metadata/MetadataManage.java
index ab423b3..58a016c 100644
--- a/tubemq-server/src/main/java/org/apache/tubemq/server/broker/metadata/MetadataManage.java
+++ b/tubemq-server/src/main/java/org/apache/tubemq/server/broker/metadata/MetadataManage.java
@@ -67,7 +67,7 @@ public interface MetadataManage {
Map<String, TopicMetadata> getRemovedTopicConfigMap();
- Integer getCosedTopicStatusId(final String topic);
+ Integer getClosedTopicStatusId(final String topic);
boolean isClosedTopic(final String topic);