You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tubemq.apache.org by go...@apache.org on 2020/01/15 11:17:58 UTC
[incubator-tubemq] branch master updated: [TUBEMQ-22] Correct
ClientSubInfo#getTopicProcesser -> ClientSubInfo#getTopicProcessor (#13)
This is an automated email from the ASF dual-hosted git repository.
gosonzhang 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 4d67dba [TUBEMQ-22] Correct ClientSubInfo#getTopicProcesser -> ClientSubInfo#getTopicProcessor (#13)
4d67dba is described below
commit 4d67dbabd6a249f30f3605f74e7578723db7c01f
Author: Tboy <gu...@immomo.com>
AuthorDate: Wed Jan 15 19:17:51 2020 +0800
[TUBEMQ-22] Correct ClientSubInfo#getTopicProcesser -> ClientSubInfo#getTopicProcessor (#13)
---
.../com/tencent/tubemq/client/consumer/BaseMessageConsumer.java | 6 +++---
.../main/java/com/tencent/tubemq/client/consumer/ClientSubInfo.java | 2 +-
.../tencent/tubemq/client/consumer/SimplePushMessageConsumer.java | 2 +-
3 files changed, 5 insertions(+), 5 deletions(-)
diff --git a/tubemq-client/src/main/java/com/tencent/tubemq/client/consumer/BaseMessageConsumer.java b/tubemq-client/src/main/java/com/tencent/tubemq/client/consumer/BaseMessageConsumer.java
index e08977d..6d5d6a8 100644
--- a/tubemq-client/src/main/java/com/tencent/tubemq/client/consumer/BaseMessageConsumer.java
+++ b/tubemq-client/src/main/java/com/tencent/tubemq/client/consumer/BaseMessageConsumer.java
@@ -262,7 +262,7 @@ public class BaseMessageConsumer implements MessageConsumer {
if ((messageListener == null) && (!this.isPullConsume)) {
throw new IllegalArgumentException("Parameter error: null messageListener");
}
- TopicProcessor topicProcessor = this.consumeSubInfo.getTopicProcesser(topic);
+ TopicProcessor topicProcessor = this.consumeSubInfo.getTopicProcessor(topic);
if (topicProcessor == null) {
final TopicProcessor oldProcessor =
this.consumeSubInfo.putIfAbsentTopicProcessor(topic,
@@ -993,7 +993,7 @@ public class BaseMessageConsumer implements MessageConsumer {
builder.setQryPriorityId(groupFlowCtrlRuleHandler.getQryPriorityId());
builder.setReadStatus(getGroupInitReadStatus());
TopicProcessor topicProcessor =
- this.consumeSubInfo.getTopicProcesser(partition.getTopic());
+ this.consumeSubInfo.getTopicProcessor(partition.getTopic());
if (topicProcessor != null && topicProcessor.getFilterConds() != null) {
builder.addAllFilterCondStr(topicProcessor.getFilterConds());
}
@@ -1246,7 +1246,7 @@ public class BaseMessageConsumer implements MessageConsumer {
// Calculate the message size and do some flow control
boolean needFilter = false;
Set<String> topicFilterSet = null;
- TopicProcessor topicProcessor = consumeSubInfo.getTopicProcesser(topic);
+ TopicProcessor topicProcessor = consumeSubInfo.getTopicProcessor(topic);
if (topicProcessor != null) {
topicFilterSet = topicProcessor.getFilterConds();
if (topicFilterSet != null && !topicFilterSet.isEmpty()) {
diff --git a/tubemq-client/src/main/java/com/tencent/tubemq/client/consumer/ClientSubInfo.java b/tubemq-client/src/main/java/com/tencent/tubemq/client/consumer/ClientSubInfo.java
index c22b880..b0b1de1 100644
--- a/tubemq-client/src/main/java/com/tencent/tubemq/client/consumer/ClientSubInfo.java
+++ b/tubemq-client/src/main/java/com/tencent/tubemq/client/consumer/ClientSubInfo.java
@@ -61,7 +61,7 @@ public class ClientSubInfo {
return this.subscribedTopics.contains(topic);
}
- public TopicProcessor getTopicProcesser(String topic) {
+ public TopicProcessor getTopicProcessor(String topic) {
return this.topicCondRegistry.get(topic);
}
diff --git a/tubemq-client/src/main/java/com/tencent/tubemq/client/consumer/SimplePushMessageConsumer.java b/tubemq-client/src/main/java/com/tencent/tubemq/client/consumer/SimplePushMessageConsumer.java
index 867ca21..a1eaae6 100644
--- a/tubemq-client/src/main/java/com/tencent/tubemq/client/consumer/SimplePushMessageConsumer.java
+++ b/tubemq-client/src/main/java/com/tencent/tubemq/client/consumer/SimplePushMessageConsumer.java
@@ -178,7 +178,7 @@ public class SimplePushMessageConsumer implements PushMessageConsumer {
} else {
try {
final TopicProcessor topicProcessor =
- baseConsumer.consumeSubInfo.getTopicProcesser(taskContext.getPartition().getTopic());
+ baseConsumer.consumeSubInfo.getTopicProcessor(taskContext.getPartition().getTopic());
if ((topicProcessor == null) || (topicProcessor.getMessageListener() == null)) {
isConsumed = false;
throw new TubeClientException(sBuilder