[rocketmq] branch develop updated: [ISSUE #2245]enhancement: expose config defaultBrokerId and connectBrokerByUser for DefaultLitePullConsumer (#2246)

[affe]

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: 张旭 <maixiaoha...@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 <zhangx...@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;
     }