[rocketmq] branch master 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 master
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


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

commit dc2074b7c82a4922e63c78deaa24e5ce9e1748c9
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;
     }