public void configure()

in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/DefaultMessageSpec.java [84:116]

• 33 lines of code
• 11 McCabe index (conditional complexity)

	public void configure(TypedMessageBuilder<T> typedMessageBuilder) {
		if (this.key != null) {
			typedMessageBuilder.key(this.key);
		}
		if (this.orderingKey != null) {
			typedMessageBuilder.orderingKey(this.orderingKey);
		}
		if (this.keyBytes != null) {
			typedMessageBuilder.keyBytes(this.keyBytes);
		}
		typedMessageBuilder.value(this.value);
		if (this.properties != null) {
			typedMessageBuilder.properties(this.properties);
		}
		if (this.eventTime != null) {
			typedMessageBuilder.eventTime(this.eventTime);
		}
		if (this.sequenceId != null) {
			typedMessageBuilder.sequenceId(this.sequenceId);
		}
		if (this.replicationClusters != null) {
			typedMessageBuilder.replicationClusters(this.replicationClusters);
		}
		if (this.disableReplication) {
			typedMessageBuilder.disableReplication();
		}
		if (this.deliverAt != null) {
			typedMessageBuilder.deliverAt(this.deliverAt);
		}
		if (this.deliverAfterDelay != null) {
			typedMessageBuilder.deliverAfter(this.deliverAfterDelay, this.deliverAfterUnit);
		}
	}