in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ImmutableReactiveMessageReaderSpec.java [53:66]
public ImmutableReactiveMessageReaderSpec(List<String> topicNames, String readerName, String subscriptionName,
String generatedSubscriptionNamePrefix, Integer receiverQueueSize, Boolean readCompacted,
List<Range> keyHashRanges, CryptoKeyReader cryptoKeyReader,
ConsumerCryptoFailureAction cryptoFailureAction) {
this.topicNames = topicNames;
this.readerName = readerName;
this.subscriptionName = subscriptionName;
this.generatedSubscriptionNamePrefix = generatedSubscriptionNamePrefix;
this.receiverQueueSize = receiverQueueSize;
this.readCompacted = readCompacted;
this.keyHashRanges = keyHashRanges;
this.cryptoKeyReader = cryptoKeyReader;
this.cryptoFailureAction = cryptoFailureAction;
}