You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by si...@apache.org on 2018/10/10 04:26:14 UTC

[pulsar] branch master updated: change constructor access for ConsumerBuilderImpl (#2759)

This is an automated email from the ASF dual-hosted git repository.

sijie pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new 362f795  change constructor access for ConsumerBuilderImpl (#2759)
362f795 is described below

commit 362f7959a610bb62993181388c071d486a50d6cd
Author: penghui <co...@gmail.com>
AuthorDate: Wed Oct 10 12:26:10 2018 +0800

    change constructor access for ConsumerBuilderImpl (#2759)
---
 .../main/java/org/apache/pulsar/client/impl/ConsumerBuilderImpl.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerBuilderImpl.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerBuilderImpl.java
index b962264..7853de5 100644
--- a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerBuilderImpl.java
+++ b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerBuilderImpl.java
@@ -61,7 +61,7 @@ public class ConsumerBuilderImpl<T> implements ConsumerBuilder<T> {
 
     private static long MIN_ACK_TIMEOUT_MILLIS = 1000;
 
-    ConsumerBuilderImpl(PulsarClientImpl client, Schema<T> schema) {
+    public ConsumerBuilderImpl(PulsarClientImpl client, Schema<T> schema) {
         this(client, new ConsumerConfigurationData<T>(), schema);
     }