rocketmq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From a...@apache.org
Subject [rocketmq] branch develop updated: [ISSUE #2245]enhancement: expose config defaultBrokerId and connectBrokerByUser for DefaultLitePullConsumer (#2246)
Date Wed, 19 Aug 2020 07:47:55 GMT
This is an automated email from the ASF dual-hosted git repository.

affe pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new 6a46640  [ISSUE #2245]enhancement: expose config defaultBrokerId and connectBrokerByUser
for DefaultLitePullConsumer (#2246)
6a46640 is described below

commit 6a466402d9cfc9fb131cad922b265157dbfcc625
Author: 张旭 <maixiaohai00@gmail.com>
AuthorDate: Wed Aug 19 15:02:06 2020 +0800

    [ISSUE #2245]enhancement: expose config defaultBrokerId and connectBrokerByUser for DefaultLitePullConsumer
(#2246)
    
    Co-authored-by: zhangxu16 <zhangxu16@xiaomi.com>
---
 .../client/consumer/DefaultLitePullConsumer.java         | 16 ++++++++++++++++
 1 file changed, 16 insertions(+)

diff --git a/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultLitePullConsumer.java
b/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultLitePullConsumer.java
index 6718eb5..9cc7c60 100644
--- a/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultLitePullConsumer.java
+++ b/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultLitePullConsumer.java
@@ -307,6 +307,22 @@ public class DefaultLitePullConsumer extends ClientConfig implements
LitePullCon
         this.autoCommit = autoCommit;
     }
 
+    public boolean isConnectBrokerByUser() {
+        return this.defaultLitePullConsumerImpl.getPullAPIWrapper().isConnectBrokerByUser();
+    }
+
+    public void setConnectBrokerByUser(boolean connectBrokerByUser) {
+        this.defaultLitePullConsumerImpl.getPullAPIWrapper().setConnectBrokerByUser(connectBrokerByUser);
+    }
+
+    public long getDefaultBrokerId() {
+        return this.defaultLitePullConsumerImpl.getPullAPIWrapper().getDefaultBrokerId();
+    }
+
+    public void setDefaultBrokerId(long defaultBrokerId) {
+        this.defaultLitePullConsumerImpl.getPullAPIWrapper().setDefaultBrokerId(defaultBrokerId);
+    }
+
     public int getPullThreadNums() {
         return pullThreadNums;
     }


Mime
View raw message