public void applySpec()

in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MutableReactiveMessageConsumerSpec.java [641:741]
101 lines of code
37 McCabe index (conditional complexity)

	public void applySpec(ReactiveMessageConsumerSpec consumerSpec) {
		if (consumerSpec.getTopicNames() != null && !consumerSpec.getTopicNames().isEmpty()) {
			setTopicNames(new ArrayList<>(consumerSpec.getTopicNames()));
		}
		if (consumerSpec.getTopicsPattern() != null) {
			setTopicsPattern(consumerSpec.getTopicsPattern());
		}
		if (consumerSpec.getTopicsPatternSubscriptionMode() != null) {
			setTopicsPatternSubscriptionMode(consumerSpec.getTopicsPatternSubscriptionMode());
		}
		if (consumerSpec.getTopicsPatternAutoDiscoveryPeriod() != null) {
			setTopicsPatternAutoDiscoveryPeriod(consumerSpec.getTopicsPatternAutoDiscoveryPeriod());
		}
		if (consumerSpec.getSubscriptionName() != null) {
			setSubscriptionName(consumerSpec.getSubscriptionName());
		}
		if (consumerSpec.getSubscriptionMode() != null) {
			setSubscriptionMode(consumerSpec.getSubscriptionMode());
		}
		if (consumerSpec.getSubscriptionType() != null) {
			setSubscriptionType(consumerSpec.getSubscriptionType());
		}
		if (consumerSpec.getSubscriptionInitialPosition() != null) {
			setSubscriptionInitialPosition(consumerSpec.getSubscriptionInitialPosition());
		}
		if (consumerSpec.getKeySharedPolicy() != null) {
			setKeySharedPolicy(consumerSpec.getKeySharedPolicy());
		}
		if (consumerSpec.getReplicateSubscriptionState() != null) {
			setReplicateSubscriptionState(consumerSpec.getReplicateSubscriptionState());
		}
		if (consumerSpec.getSubscriptionProperties() != null && !consumerSpec.getSubscriptionProperties().isEmpty()) {
			setSubscriptionProperties(new LinkedHashMap<>(consumerSpec.getSubscriptionProperties()));
		}
		if (consumerSpec.getConsumerName() != null) {
			setConsumerName(consumerSpec.getConsumerName());
		}
		if (consumerSpec.getProperties() != null && !consumerSpec.getProperties().isEmpty()) {
			setProperties(new LinkedHashMap<>(consumerSpec.getProperties()));
		}
		if (consumerSpec.getPriorityLevel() != null) {
			setPriorityLevel(consumerSpec.getPriorityLevel());
		}
		if (consumerSpec.getReadCompacted() != null) {
			setReadCompacted(consumerSpec.getReadCompacted());
		}
		if (consumerSpec.getBatchIndexAckEnabled() != null) {
			setBatchIndexAckEnabled(consumerSpec.getBatchIndexAckEnabled());
		}
		if (consumerSpec.getAckTimeout() != null) {
			setAckTimeout(consumerSpec.getAckTimeout());
		}
		if (consumerSpec.getAckTimeoutTickTime() != null) {
			setAckTimeoutTickTime(consumerSpec.getAckTimeoutTickTime());
		}
		if (consumerSpec.getAcknowledgementsGroupTime() != null) {
			setAcknowledgementsGroupTime(consumerSpec.getAcknowledgementsGroupTime());
		}
		if (consumerSpec.getAcknowledgeAsynchronously() != null) {
			setAcknowledgeAsynchronously(consumerSpec.getAcknowledgeAsynchronously());
		}
		if (consumerSpec.getAcknowledgeScheduler() != null) {
			setAcknowledgeScheduler(consumerSpec.getAcknowledgeScheduler());
		}
		if (consumerSpec.getNegativeAckRedeliveryDelay() != null) {
			setNegativeAckRedeliveryDelay(consumerSpec.getNegativeAckRedeliveryDelay());
		}
		if (consumerSpec.getDeadLetterPolicy() != null) {
			setDeadLetterPolicy(consumerSpec.getDeadLetterPolicy());
		}
		if (consumerSpec.getRetryLetterTopicEnable() != null) {
			setRetryLetterTopicEnable(consumerSpec.getRetryLetterTopicEnable());
		}
		if (consumerSpec.getReceiverQueueSize() != null) {
			setReceiverQueueSize(consumerSpec.getReceiverQueueSize());
		}
		if (consumerSpec.getMaxTotalReceiverQueueSizeAcrossPartitions() != null) {
			setMaxTotalReceiverQueueSizeAcrossPartitions(consumerSpec.getMaxTotalReceiverQueueSizeAcrossPartitions());
		}
		if (consumerSpec.getAutoUpdatePartitions() != null) {
			setAutoUpdatePartitions(consumerSpec.getAutoUpdatePartitions());
		}
		if (consumerSpec.getAutoUpdatePartitionsInterval() != null) {
			setAutoUpdatePartitionsInterval(consumerSpec.getAutoUpdatePartitionsInterval());
		}
		if (consumerSpec.getCryptoKeyReader() != null) {
			setCryptoKeyReader(consumerSpec.getCryptoKeyReader());
		}
		if (consumerSpec.getCryptoFailureAction() != null) {
			setCryptoFailureAction(consumerSpec.getCryptoFailureAction());
		}
		if (consumerSpec.getMaxPendingChunkedMessage() != null) {
			setMaxPendingChunkedMessage(consumerSpec.getMaxPendingChunkedMessage());
		}
		if (consumerSpec.getAutoAckOldestChunkedMessageOnQueueFull() != null) {
			setAutoAckOldestChunkedMessageOnQueueFull(consumerSpec.getAutoAckOldestChunkedMessageOnQueueFull());
		}
		if (consumerSpec.getExpireTimeOfIncompleteChunkedMessage() != null) {
			setExpireTimeOfIncompleteChunkedMessage(consumerSpec.getExpireTimeOfIncompleteChunkedMessage());
		}
	}