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

lhotari pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pulsar-client-reactive.git


The following commit(s) were added to refs/heads/main by this push:
     new 1d344db  Rename ReactiveMessageConsumerBuilder::topicNames to 
ReactiveMessageConsumerBuilder::topics (#42)
1d344db is described below

commit 1d344dbf278e824529b382f49bd0e7f11fa31e8e
Author: Christophe Bornet <[email protected]>
AuthorDate: Mon Nov 28 11:48:41 2022 +0100

    Rename ReactiveMessageConsumerBuilder::topicNames to 
ReactiveMessageConsumerBuilder::topics (#42)
---
 .../pulsar/reactive/client/api/ReactiveMessageConsumerBuilder.java      | 2 +-
 .../apache/pulsar/reactive/client/api/ReactiveMessageReaderBuilder.java | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageConsumerBuilder.java
 
b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageConsumerBuilder.java
index 8a699a2..8cce613 100644
--- 
a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageConsumerBuilder.java
+++ 
b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageConsumerBuilder.java
@@ -103,7 +103,7 @@ public interface ReactiveMessageConsumerBuilder<T> {
         * @param topicNames a set of topic that the consumer will subscribe on
         * @return the consumer builder instance
         */
-       default ReactiveMessageConsumerBuilder<T> topicNames(List<String> 
topicNames) {
+       default ReactiveMessageConsumerBuilder<T> topics(List<String> 
topicNames) {
                getMutableSpec().setTopicNames(topicNames);
                return this;
        }
diff --git 
a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageReaderBuilder.java
 
b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageReaderBuilder.java
index beb02f5..804ea7b 100644
--- 
a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageReaderBuilder.java
+++ 
b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageReaderBuilder.java
@@ -123,7 +123,7 @@ public interface ReactiveMessageReaderBuilder<T> {
         * @return the reader builder instance
         * @see ReaderBuilder#topics(List)
         */
-       default ReactiveMessageReaderBuilder<T> topicNames(List<String> 
topicNames) {
+       default ReactiveMessageReaderBuilder<T> topics(List<String> topicNames) 
{
                getMutableSpec().setTopicNames(topicNames);
                return this;
        }

Reply via email to