public void applySpec()

in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MutableReactiveMessageReaderSpec.java [200:228]

• 29 lines of code
• 12 McCabe index (conditional complexity)

	public void applySpec(ReactiveMessageReaderSpec readerSpec) {
		if (readerSpec.getTopicNames() != null && !readerSpec.getTopicNames().isEmpty()) {
			setTopicNames(new ArrayList<>(readerSpec.getTopicNames()));
		}
		if (readerSpec.getReaderName() != null) {
			setReaderName(readerSpec.getReaderName());
		}
		if (readerSpec.getSubscriptionName() != null) {
			setSubscriptionName(readerSpec.getSubscriptionName());
		}
		if (readerSpec.getGeneratedSubscriptionNamePrefix() != null) {
			setGeneratedSubscriptionNamePrefix(readerSpec.getGeneratedSubscriptionNamePrefix());
		}
		if (readerSpec.getReceiverQueueSize() != null) {
			setReceiverQueueSize(readerSpec.getReceiverQueueSize());
		}
		if (readerSpec.getReadCompacted() != null) {
			setReadCompacted(readerSpec.getReadCompacted());
		}
		if (readerSpec.getKeyHashRanges() != null && !readerSpec.getKeyHashRanges().isEmpty()) {
			setKeyHashRanges(new ArrayList<>(readerSpec.getKeyHashRanges()));
		}
		if (readerSpec.getCryptoKeyReader() != null) {
			setCryptoKeyReader(readerSpec.getCryptoKeyReader());
		}
		if (readerSpec.getCryptoFailureAction() != null) {
			setCryptoFailureAction(readerSpec.getCryptoFailureAction());
		}
	}