lhotari commented on code in PR #28:
URL:
https://github.com/apache/pulsar-client-reactive/pull/28#discussion_r1033293830
##########
pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageSenderBuilder.java:
##########
@@ -28,156 +28,555 @@
import org.apache.pulsar.client.api.MessageRoutingMode;
import org.apache.pulsar.client.api.ProducerAccessMode;
import org.apache.pulsar.client.api.ProducerCryptoFailureAction;
+import org.reactivestreams.Publisher;
+/**
+ * Builder interface for {@link ReactiveMessageSender}.
+ *
+ * @param <T> the message payload type
+ * @author Lari Hotari
+ * @author Christophe Bornet
+ */
public interface ReactiveMessageSenderBuilder<T> {
+ /**
+ * Sets the cache to use for the sender.
+ * @param producerCache the cache to set
+ * @return the sender builder instance
+ */
ReactiveMessageSenderBuilder<T> cache(ReactiveMessageSenderCache
producerCache);
+ /**
+ * Sets the maximum number of in-flight messages for the sender. When
this value is
+ * reached, backpressure will be triggered on the
+ * {@link ReactiveMessageSender#sendOne(MessageSpec)}/{@link
ReactiveMessageSender#sendMany(Publisher)}
+ * operations. Note that the maxInflight setting applies globally for
all the
+ * operations called on the sender.
Review Comment:
Added #38
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
