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/01 01:03:33 UTC
[pulsar] branch master updated: Change access to public for method
getProducers(). (#2663)
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 e7930f3 Change access to public for method getProducers(). (#2663)
e7930f3 is described below
commit e7930f3d97cf64292aa507afeca6da824d714c60
Author: penghui <co...@gmail.com>
AuthorDate: Mon Oct 1 09:03:29 2018 +0800
Change access to public for method getProducers(). (#2663)
### Motivation
Need to get stats from producers in PartitionedProducerImpl.
### Modifications
Change access to public for method getProducers().
---
.../java/org/apache/pulsar/client/impl/PartitionedProducerImpl.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/PartitionedProducerImpl.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/PartitionedProducerImpl.java
index 8c4387e..a6f40fe 100644
--- a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/PartitionedProducerImpl.java
+++ b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/PartitionedProducerImpl.java
@@ -237,7 +237,7 @@ public class PartitionedProducerImpl<T> extends ProducerBase<T> {
private static final Logger log = LoggerFactory.getLogger(PartitionedProducerImpl.class);
- protected List<ProducerImpl<T>> getProducers() {
+ public List<ProducerImpl<T>> getProducers() {
return producers.stream().collect(Collectors.toList());
}