public void applySpec()

in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MutableReactiveMessageSenderSpec.java [493:598]
81 lines of code
29 McCabe index (conditional complexity)

	public void applySpec(ReactiveMessageSenderSpec senderSpec) {
		if (senderSpec.getTopicName() != null) {
			setTopicName(senderSpec.getTopicName());
		}

		if (senderSpec.getProducerName() != null) {
			setProducerName(senderSpec.getProducerName());
		}

		if (senderSpec.getSendTimeout() != null) {
			setSendTimeout(senderSpec.getSendTimeout());
		}

		if (senderSpec.getMaxPendingMessages() != null) {
			setMaxPendingMessages(senderSpec.getMaxPendingMessages());
		}

		if (senderSpec.getMaxPendingMessagesAcrossPartitions() != null) {
			setMaxPendingMessagesAcrossPartitions(senderSpec.getMaxPendingMessagesAcrossPartitions());
		}

		if (senderSpec.getMessageRoutingMode() != null) {
			setMessageRoutingMode(senderSpec.getMessageRoutingMode());
		}

		if (senderSpec.getHashingScheme() != null) {
			setHashingScheme(senderSpec.getHashingScheme());
		}

		if (senderSpec.getCryptoFailureAction() != null) {
			setCryptoFailureAction(senderSpec.getCryptoFailureAction());
		}

		if (senderSpec.getMessageRouter() != null) {
			setMessageRouter(senderSpec.getMessageRouter());
		}

		if (senderSpec.getBatchingMaxPublishDelay() != null) {
			setBatchingMaxPublishDelay(senderSpec.getBatchingMaxPublishDelay());
		}

		if (senderSpec.getRoundRobinRouterBatchingPartitionSwitchFrequency() != null) {
			setRoundRobinRouterBatchingPartitionSwitchFrequency(
					senderSpec.getRoundRobinRouterBatchingPartitionSwitchFrequency());
		}

		if (senderSpec.getBatchingMaxMessages() != null) {
			setBatchingMaxMessages(senderSpec.getBatchingMaxMessages());
		}

		if (senderSpec.getBatchingMaxBytes() != null) {
			setBatchingMaxBytes(senderSpec.getBatchingMaxBytes());
		}

		if (senderSpec.getBatchingEnabled() != null) {
			setBatchingEnabled(senderSpec.getBatchingEnabled());
		}

		if (senderSpec.getBatcherBuilder() != null) {
			setBatcherBuilder(senderSpec.getBatcherBuilder());
		}

		if (senderSpec.getChunkingEnabled() != null) {
			setChunkingEnabled(senderSpec.getChunkingEnabled());
		}

		if (senderSpec.getCryptoKeyReader() != null) {
			setCryptoKeyReader(senderSpec.getCryptoKeyReader());
		}

		if (senderSpec.getEncryptionKeys() != null && !senderSpec.getEncryptionKeys().isEmpty()) {
			setEncryptionKeys(new HashSet<>(senderSpec.getEncryptionKeys()));
		}

		if (senderSpec.getCompressionType() != null) {
			setCompressionType(senderSpec.getCompressionType());
		}

		if (senderSpec.getInitialSequenceId() != null) {
			setInitialSequenceId(senderSpec.getInitialSequenceId());
		}

		if (senderSpec.getAutoUpdatePartitions() != null) {
			setAutoUpdatePartitions(senderSpec.getAutoUpdatePartitions());
		}

		if (senderSpec.getAutoUpdatePartitionsInterval() != null) {
			setAutoUpdatePartitionsInterval(senderSpec.getAutoUpdatePartitionsInterval());
		}

		if (senderSpec.getMultiSchema() != null) {
			setMultiSchema(senderSpec.getMultiSchema());
		}

		if (senderSpec.getAccessMode() != null) {
			setAccessMode(senderSpec.getAccessMode());
		}

		if (senderSpec.getLazyStartPartitionedProducers() != null) {
			setLazyStartPartitionedProducers(senderSpec.getLazyStartPartitionedProducers());
		}

		if (senderSpec.getProperties() != null && !senderSpec.getProperties().isEmpty()) {
			setProperties(new LinkedHashMap<>(senderSpec.getProperties()));
		}
	}