You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by pe...@apache.org on 2021/12/20 11:57:03 UTC
[pulsar] 13/22: Optimize the code: remove extra spaces (#12470)
This is an automated email from the ASF dual-hosted git repository.
penghui pushed a commit to branch branch-2.9
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit bc50bac64ab53e4c2b06932b459fb9aeaefe5924
Author: chenlin <15...@qq.com>
AuthorDate: Sun Oct 24 12:28:29 2021 +0800
Optimize the code: remove extra spaces (#12470)
(cherry picked from commit 95e6a0edd74d51b2275ae24083276259d7a92f91)
---
.../src/main/java/org/apache/pulsar/client/impl/ConsumerBase.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerBase.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerBase.java
index 7d6474b..9312df5 100644
--- a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerBase.java
+++ b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerBase.java
@@ -717,13 +717,13 @@ public abstract class ConsumerBase<T> extends HandlerState implements Consumer<T
protected void onAckTimeoutSend(Set<MessageId> messageIds) {
if (interceptors != null) {
- interceptors. onAckTimeoutSend(this, messageIds);
+ interceptors.onAckTimeoutSend(this, messageIds);
}
}
protected void onPartitionsChange(String topicName, int partitions) {
if (interceptors != null) {
- interceptors. onPartitionsChange(topicName, partitions);
+ interceptors.onPartitionsChange(topicName, partitions);
}
}