You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by lh...@apache.org on 2025/06/11 08:46:27 UTC
(pulsar-client-reactive) branch main updated: Deprecate public constructor in ImmutableReactiveMessageConsumerSpec (#222)
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 20e62c5 Deprecate public constructor in ImmutableReactiveMessageConsumerSpec (#222)
20e62c5 is described below
commit 20e62c5f3ab5d560b4a92d6a9cb3616d4383912e
Author: Chris Bono <on...@apache.org>
AuthorDate: Wed Jun 11 03:46:21 2025 -0500
Deprecate public constructor in ImmutableReactiveMessageConsumerSpec (#222)
This commit deprecates the current public constructor with all fields
in favor of a package-protected variant. The constructor was initially
added to support Jackson serde but it did not need to be public.
Resolves #221
---
.../api/ImmutableReactiveMessageConsumerSpec.java | 163 +++++++++++++++++++++
1 file changed, 163 insertions(+)
diff --git a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ImmutableReactiveMessageConsumerSpec.java b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ImmutableReactiveMessageConsumerSpec.java
index 3291073..7c9886b 100644
--- a/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ImmutableReactiveMessageConsumerSpec.java
+++ b/pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ImmutableReactiveMessageConsumerSpec.java
@@ -191,7 +191,170 @@ public class ImmutableReactiveMessageConsumerSpec implements ReactiveMessageCons
this.expireTimeOfIncompleteChunkedMessage = consumerSpec.getExpireTimeOfIncompleteChunkedMessage();
}
+ /**
+ * Constructs an instance with the specified parameters.
+ * @param topicNames the topics to subscribe to
+ * @param topicsPattern the topics pattern of the topics to subscribe to
+ * @param topicsPatternSubscriptionMode the type of topics to subscribe to when using
+ * a topic pattern - Persistent, Non-Persistent, or both
+ * @param topicsPatternAutoDiscoveryPeriod the topics auto discovery period when using
+ * a topic pattern
+ * @param subscriptionName the subscription name
+ * @param subscriptionMode the subscription mode
+ * @param subscriptionType the subscription type
+ * @param subscriptionInitialPosition the subscription initial position
+ * @param keySharedPolicy the policy used for {@link SubscriptionType#Key_Shared}
+ * subscriptions
+ * @param replicateSubscriptionState whether the subscription shall be replicated
+ * @param subscriptionProperties the properties for the subscription
+ * @param consumerName the consumer name
+ * @param properties the consumer properties
+ * @param priorityLevel the priority level for the consumer to which a broker gives
+ * more priority while dispatching messages
+ * @param readCompacted whether to read messages from the compacted topic rather than
+ * reading the full message backlog of the topic
+ * @param batchIndexAckEnabled whether batch index acknowledgement is enabled
+ * @param ackTimeout the timeout duration for unacknowledged messages
+ * @param ackTimeoutTickTime the tick time of the ack-timeout redelivery
+ * @param acknowledgementsGroupTime the duration used to group acknowledgements
+ * @param acknowledgeAsynchronously whether to ignore the acknowledge operation
+ * completion and make it asynchronous from the message consuming processing to
+ * improve performance by allowing the acknowledges and message processing to
+ * interleave
+ * @param acknowledgeScheduler the scheduler to use to handle acknowledgements
+ * @param negativeAckRedeliveryDelay the delay to wait before re-delivering messages
+ * that have failed to be processed
+ * @param deadLetterPolicy the dead letter policy for the consumer
+ * @param retryLetterTopicEnable whether the retries are enabled
+ * @param receiverQueueSize the size of the consumer receive queue
+ * @param maxTotalReceiverQueueSizeAcrossPartitions the maximum total receiver queue
+ * size across partitions
+ * @param autoUpdatePartitions whether the consumer shall subscribe automatically to
+ * new partitions of partitioned topics
+ * @param autoUpdatePartitionsInterval the interval of updating partitions when
+ * autoUpdatePartitions is enabled
+ * @param cryptoKeyReader the key reader to be used to decrypt the message payloads
+ * @param cryptoFailureAction the action the consumer will take in case of decryption
+ * failures
+ * @param maxPendingChunkedMessage the maximum number of messages in the queue holding
+ * pending chunked messages
+ * @param autoAckOldestChunkedMessageOnQueueFull whether to automatically acknowledge
+ * pending chunked messages when maxPendingChunkedMessage is reached
+ * @param expireTimeOfIncompleteChunkedMessage the time interval to expire incomplete
+ * chunks if a consumer fails to receive all the chunks
+ * @deprecated since 0.7.0 for removal in 0.9.0 in favor of
+ * {@link #ImmutableReactiveMessageConsumerSpec(List, Pattern, RegexSubscriptionMode, Duration, String, SubscriptionMode, SubscriptionType, SubscriptionInitialPosition, KeySharedPolicy, Boolean, Map, String, Map, Integer, Boolean, Boolean, Duration, Duration, Duration, Boolean, Scheduler, Duration, RedeliveryBackoff, RedeliveryBackoff, DeadLetterPolicy, Boolean, Integer, Integer, Boolean, Duration, CryptoKeyReader, ConsumerCryptoFailureAction, Integer, Boolean, Duration)}
+ */
+ @Deprecated
public ImmutableReactiveMessageConsumerSpec(List<String> topicNames, Pattern topicsPattern,
+ RegexSubscriptionMode topicsPatternSubscriptionMode, Duration topicsPatternAutoDiscoveryPeriod,
+ String subscriptionName, SubscriptionMode subscriptionMode, SubscriptionType subscriptionType,
+ SubscriptionInitialPosition subscriptionInitialPosition, KeySharedPolicy keySharedPolicy,
+ Boolean replicateSubscriptionState, Map<String, String> subscriptionProperties, String consumerName,
+ Map<String, String> properties, Integer priorityLevel, Boolean readCompacted, Boolean batchIndexAckEnabled,
+ Duration ackTimeout, Duration ackTimeoutTickTime, Duration acknowledgementsGroupTime,
+ Boolean acknowledgeAsynchronously, Scheduler acknowledgeScheduler, Duration negativeAckRedeliveryDelay,
+ DeadLetterPolicy deadLetterPolicy, Boolean retryLetterTopicEnable, Integer receiverQueueSize,
+ Integer maxTotalReceiverQueueSizeAcrossPartitions, Boolean autoUpdatePartitions,
+ Duration autoUpdatePartitionsInterval, CryptoKeyReader cryptoKeyReader,
+ ConsumerCryptoFailureAction cryptoFailureAction, Integer maxPendingChunkedMessage,
+ Boolean autoAckOldestChunkedMessageOnQueueFull, Duration expireTimeOfIncompleteChunkedMessage) {
+ this.topicNames = topicNames;
+ this.topicsPattern = topicsPattern;
+ this.topicsPatternSubscriptionMode = topicsPatternSubscriptionMode;
+ this.topicsPatternAutoDiscoveryPeriod = topicsPatternAutoDiscoveryPeriod;
+ this.subscriptionName = subscriptionName;
+ this.subscriptionMode = subscriptionMode;
+ this.subscriptionType = subscriptionType;
+ this.subscriptionInitialPosition = subscriptionInitialPosition;
+ this.keySharedPolicy = keySharedPolicy;
+ this.replicateSubscriptionState = replicateSubscriptionState;
+ this.subscriptionProperties = subscriptionProperties;
+ this.consumerName = consumerName;
+ this.properties = properties;
+ this.priorityLevel = priorityLevel;
+ this.readCompacted = readCompacted;
+ this.batchIndexAckEnabled = batchIndexAckEnabled;
+ this.ackTimeout = ackTimeout;
+ this.ackTimeoutTickTime = ackTimeoutTickTime;
+ this.acknowledgementsGroupTime = acknowledgementsGroupTime;
+ this.acknowledgeAsynchronously = acknowledgeAsynchronously;
+ this.acknowledgeScheduler = acknowledgeScheduler;
+ this.negativeAckRedeliveryDelay = negativeAckRedeliveryDelay;
+ this.negativeAckRedeliveryBackoff = null;
+ this.ackTimeoutRedeliveryBackoff = null;
+ this.deadLetterPolicy = deadLetterPolicy;
+ this.retryLetterTopicEnable = retryLetterTopicEnable;
+ this.receiverQueueSize = receiverQueueSize;
+ this.maxTotalReceiverQueueSizeAcrossPartitions = maxTotalReceiverQueueSizeAcrossPartitions;
+ this.autoUpdatePartitions = autoUpdatePartitions;
+ this.autoUpdatePartitionsInterval = autoUpdatePartitionsInterval;
+ this.cryptoKeyReader = cryptoKeyReader;
+ this.cryptoFailureAction = cryptoFailureAction;
+ this.maxPendingChunkedMessage = maxPendingChunkedMessage;
+ this.autoAckOldestChunkedMessageOnQueueFull = autoAckOldestChunkedMessageOnQueueFull;
+ this.expireTimeOfIncompleteChunkedMessage = expireTimeOfIncompleteChunkedMessage;
+ }
+
+ /**
+ * Constructs an instance with the specified parameters. Intended for use by the
+ * Jackson mixin for the Jackson serde.
+ * @param topicNames the topics to subscribe to
+ * @param topicsPattern the topics pattern of the topics to subscribe to
+ * @param topicsPatternSubscriptionMode the type of topics to subscribe to when using
+ * a topic pattern - Persistent, Non-Persistent, or both
+ * @param topicsPatternAutoDiscoveryPeriod the topics auto discovery period when using
+ * a topic pattern
+ * @param subscriptionName the subscription name
+ * @param subscriptionMode the subscription mode
+ * @param subscriptionType the subscription type
+ * @param subscriptionInitialPosition the subscription initial position
+ * @param keySharedPolicy the policy used for {@link SubscriptionType#Key_Shared}
+ * subscriptions
+ * @param replicateSubscriptionState whether the subscription shall be replicated
+ * @param subscriptionProperties the properties for the subscription
+ * @param consumerName the consumer name
+ * @param properties the consumer properties
+ * @param priorityLevel the priority level for the consumer to which a broker gives
+ * more priority while dispatching messages
+ * @param readCompacted whether to read messages from the compacted topic rather than
+ * reading the full message backlog of the topic
+ * @param batchIndexAckEnabled whether batch index acknowledgement is enabled
+ * @param ackTimeout the timeout duration for unacknowledged messages
+ * @param ackTimeoutTickTime the tick time of the ack-timeout redelivery
+ * @param acknowledgementsGroupTime the duration used to group acknowledgements
+ * @param acknowledgeAsynchronously whether to ignore the acknowledge operation
+ * completion and make it asynchronous from the message consuming processing to
+ * improve performance by allowing the acknowledges and message processing to
+ * interleave
+ * @param acknowledgeScheduler the scheduler to use to handle acknowledgements
+ * @param negativeAckRedeliveryDelay the delay to wait before re-delivering messages
+ * that have failed to be processed
+ * @param deadLetterPolicy the dead letter policy for the consumer
+ * @param negativeAckRedeliveryBackoff the redelivery backoff policy for messages that
+ * are negatively acknowledged
+ * @param ackTimeoutRedeliveryBackoff the redelivery backoff policy for messages that
+ * are redelivered due to acknowledgement timeout
+ * @param retryLetterTopicEnable whether the retries are enabled
+ * @param receiverQueueSize the size of the consumer receive queue
+ * @param maxTotalReceiverQueueSizeAcrossPartitions the maximum total receiver queue
+ * size across partitions
+ * @param autoUpdatePartitions whether the consumer shall subscribe automatically to
+ * new partitions of partitioned topics
+ * @param autoUpdatePartitionsInterval the interval of updating partitions when
+ * autoUpdatePartitions is enabled
+ * @param cryptoKeyReader the key reader to be used to decrypt the message payloads
+ * @param cryptoFailureAction the action the consumer will take in case of decryption
+ * failures
+ * @param maxPendingChunkedMessage the maximum number of messages in the queue holding
+ * pending chunked messages
+ * @param autoAckOldestChunkedMessageOnQueueFull whether to automatically acknowledge
+ * pending chunked messages when maxPendingChunkedMessage is reached
+ * @param expireTimeOfIncompleteChunkedMessage the time interval to expire incomplete
+ * chunks if a consumer fails to receive all the chunks
+ */
+ @SuppressWarnings("unused")
+ ImmutableReactiveMessageConsumerSpec(List<String> topicNames, Pattern topicsPattern,
RegexSubscriptionMode topicsPatternSubscriptionMode, Duration topicsPatternAutoDiscoveryPeriod,
String subscriptionName, SubscriptionMode subscriptionMode, SubscriptionType subscriptionType,
SubscriptionInitialPosition subscriptionInitialPosition, KeySharedPolicy keySharedPolicy,