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